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();