From d50fa8fb5b8f77440d43f93c1bc49cf3843f2031 Mon Sep 17 00:00:00 2001
From: dongsj <90449228+eric9204@users.noreply.github.com>
Date: Mon, 23 Sep 2024 08:02:19 +0000
Subject: [PATCH] [flink] Make MultiUnawaureTablesReader use its own logger

---
 .../flink/source/operator/MultiUnawareTablesReadOperator.java | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/operator/MultiUnawareTablesReadOperator.java b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/operator/MultiUnawareTablesReadOperator.java
index 4dba03cf4341..c501c2519b41 100644
--- a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/operator/MultiUnawareTablesReadOperator.java
+++ b/paimon-flink/paimon-flink-common/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;