From 7b2472bebb7c6cfa3c43d8df39fbdd87e4ff155b Mon Sep 17 00:00:00 2001 From: liuyang Date: Thu, 18 Apr 2024 11:13:27 +0800 Subject: [PATCH] =?UTF-8?q?fix(StreamLoadProperties):=E8=AE=BE=E7=BD=AE?= =?UTF-8?q?=E9=BB=98=E8=AE=A4=E8=A1=A8=E5=92=8Cdatabase=E5=88=A4=E6=96=AD?= =?UTF-8?q?=E9=94=99=E8=AF=AF,=E5=AF=BC=E8=87=B4=E6=B7=BB=E5=8A=A0?= =?UTF-8?q?=E7=9A=84properties=E6=97=A0=E6=B3=95=E7=94=9F=E6=95=88?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 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 118a168c..3adc308a 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();