Skip to content

Commit 0e81e46

Browse files
committed
[hotfix-37225][core] 修复 hbase报build rowKey with field system_table which value not found。
1 parent d5215bb commit 0e81e46

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

core/src/main/java/com/dtstack/flink/sql/util/TableUtils.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -758,8 +758,7 @@ public static void addConstant(Map<String, Object> keyMap, AbstractSideTableInfo
758758
List<PredicateInfo> predicateInfos = sideTableInfo.getPredicateInfoes();
759759
final String name = sideTableInfo.getName();
760760
for (PredicateInfo info : predicateInfos) {
761-
if (info.getOwnerTable().equals(name)
762-
&& info.getOperatorName().equals("=")) {
761+
if (info.getOperatorName().equals("=")) {
763762
String condition = info.getCondition();
764763
Matcher matcher = stringPattern.matcher(condition);
765764
if (matcher.matches()) {

0 commit comments

Comments
 (0)