[flink] Make MultiUnawaureTablesReader use its own logger (apache#4253)

askwang · Sep 25, 2024 · 22e6bd3 · 22e6bd3
1 parent 2c3caae
commit 22e6bd3
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...src/main/java/org/apache/paimon/flink/source/operator/MultiUnawareTablesReadOperator.java b/...src/main/java/org/apache/paimon/flink/source/operator/MultiUnawareTablesReadOperator.java
@@ -30,6 +30,8 @@
 import org.apache.flink.streaming.api.operators.AbstractStreamOperator;
 import org.apache.flink.streaming.api.operators.OneInputStreamOperator;
 import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import java.time.Duration;
 import java.time.LocalDateTime;
@@ -50,6 +52,8 @@ public class MultiUnawareTablesReadOperator
                 MultiTableUnawareAppendCompactionTask, MultiTableUnawareAppendCompactionTask> {
     private static final long serialVersionUID = 1L;
 
+    private static final Logger LOG = LoggerFactory.getLogger(MultiUnawareTablesReadOperator.class);
+
     private final Catalog.Loader catalogLoader;
 
     private final Duration partitionIdleTime;