fix

JNSimba · Feb 29, 2024 · b5e0b7c · b5e0b7c
1 parent e4a24f6
commit b5e0b7c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...va/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumDataChange.java b/...va/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumDataChange.java
@@ -69,7 +69,7 @@ public DorisRecord serialize(String record, JsonNode recordRoot, String op) thro
                 JsonDebeziumChangeUtils.getDorisTableIdentifier(
                         cdcTableIdentifier, dorisOptions, tableMapping);
         if (StringUtils.isNullOrWhitespaceOnly(dorisTableIdentifier)) {
-            LOG.debug(
+            LOG.warn(
                     "filter table {}, because it is not listened, record detail is {}",
                     cdcTableIdentifier,
                     record);