rm unused table loader copy

apache · Dec 5, 2023 · bd0dd16 · bd0dd16
1 parent f632172
commit bd0dd16
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/source/IcebergSource.java b/flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/source/IcebergSource.java
@@ -190,7 +190,6 @@ private SplitEnumerator<IcebergSourceSplit, IcebergEnumeratorState> createEnumer
           tableName);
       assigner = assignerFactory.createAssigner(enumState.pendingSplits());
     }
-    TableLoader tableLoaderCopy = tableLoader.clone();
     if (scanContext.isStreaming()) {
       ContinuousSplitPlanner splitPlanner =
           new ContinuousSplitPlannerImpl(tableLoader, scanContext, planningThreadName());