fix

yuzelin · Oct 28, 2024 · 1b83377 · 1b83377
1 parent 981ad67
commit 1b83377
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/...paimon-flink-common/src/main/java/org/apache/paimon/flink/source/BaseDataTableSource.java b/...paimon-flink-common/src/main/java/org/apache/paimon/flink/source/BaseDataTableSource.java
@@ -51,8 +51,6 @@
 import org.apache.flink.table.expressions.AggregateExpression;
 import org.apache.flink.table.factories.DynamicTableFactory;
 import org.apache.flink.table.types.DataType;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import javax.annotation.Nullable;
 
@@ -84,8 +82,6 @@
 public abstract class BaseDataTableSource extends FlinkTableSource
         implements LookupTableSource, SupportsWatermarkPushDown, SupportsAggregatePushDown {
 
-    private static final Logger LOG = LoggerFactory.getLogger(BaseDataTableSource.class);
-
     private static final List<ConfigOption<?>> TIME_TRAVEL_OPTIONS =
             Arrays.asList(
                     CoreOptions.SCAN_TIMESTAMP,