Skip to content

Commit cc8689d

Browse files
authored
[BugFix] Fail to add custom stream load table properties (#356)
Signed-off-by: liuyang <young.liu@mirmiles.com>
1 parent eb5f205 commit cc8689d

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/properties/StreamLoadProperties.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -167,7 +167,7 @@ public StreamLoadTableProperties getDefaultTableProperties() {
167167

168168
public StreamLoadTableProperties getTableProperties(String uniqueKey, String database, String table) {
169169
StreamLoadTableProperties tableProperties = tablePropertiesMap.getOrDefault(uniqueKey, defaultTableProperties);
170-
if (!tableProperties.getDatabase().equals(database) || !tableProperties.getDatabase().equals(table)) {
170+
if (!tableProperties.getDatabase().equals(database) || !tableProperties.getTable().equals(table)) {
171171
StreamLoadTableProperties.Builder tablePropertiesBuilder = StreamLoadTableProperties.builder();
172172
tablePropertiesBuilder = tablePropertiesBuilder.copyFrom(tableProperties).database(database).table(table);
173173
return tablePropertiesBuilder.build();

0 commit comments

Comments
 (0)