From cc8689d6ab75f68416491a1b841bdea1eaf85f4f Mon Sep 17 00:00:00 2001 From: Lyang77 <563647186@qq.com> Date: Mon, 29 Apr 2024 16:02:09 +0800 Subject: [PATCH] [BugFix] Fail to add custom stream load table properties (#356) Signed-off-by: liuyang --- .../data/load/stream/properties/StreamLoadProperties.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/properties/StreamLoadProperties.java b/starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/properties/StreamLoadProperties.java index e09acd93..5fa1edff 100644 --- a/starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/properties/StreamLoadProperties.java +++ b/starrocks-stream-load-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();