[BugFix] Fail to add custom stream load table properties (StarRocks#356)

Signed-off-by: liuyang <[email protected]>
hhoao · Apr 29, 2024 · cc8689d · cc8689d
1 parent eb5f205
commit cc8689d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...oad-sdk/src/main/java/com/starrocks/data/load/stream/properties/StreamLoadProperties.java b/...oad-sdk/src/main/java/com/starrocks/data/load/stream/properties/StreamLoadProperties.java
@@ -167,7 +167,7 @@ public StreamLoadTableProperties getDefaultTableProperties() {
 
     public StreamLoadTableProperties getTableProperties(String uniqueKey, String database, String table) {
         StreamLoadTableProperties tableProperties = tablePropertiesMap.getOrDefault(uniqueKey, defaultTableProperties);
-        if (!tableProperties.getDatabase().equals(database) || !tableProperties.getDatabase().equals(table)) {
+        if (!tableProperties.getDatabase().equals(database) || !tableProperties.getTable().equals(table)) {
             StreamLoadTableProperties.Builder tablePropertiesBuilder = StreamLoadTableProperties.builder();
             tablePropertiesBuilder = tablePropertiesBuilder.copyFrom(tableProperties).database(database).table(table);
             return tablePropertiesBuilder.build();