Update KuduDynamicTableSource.java

collabH · Aug 19, 2021 · 678d4bc · 678d4bc
1 parent fe7607b
commit 678d4bc
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/java/org/colloh/flink/kudu/connector/table/source/KuduDynamicTableSource.java b/src/main/java/org/colloh/flink/kudu/connector/table/source/KuduDynamicTableSource.java
@@ -55,7 +55,7 @@ public class KuduDynamicTableSource implements ScanTableSource, SupportsProjecti
 
     private static final Logger LOG = LoggerFactory.getLogger(KuduDynamicTableSource.class);
 
-    private final KuduReaderConfig.Builder configBuilder;
+    private KuduReaderConfig.Builder configBuilder;
     private final KuduTableInfo tableInfo;
     private TableSchema physicalSchema;
     private final String[] projectedFields;
@@ -157,7 +157,7 @@ public int hashCode() {
 
     @Override
     public void applyLimit(long limit) {
-        configBuilder.setRowLimit((int) limit);
+       this.configBuilder=this.configBuilder.setRowLimit((int) limit);
     }
 
     @Override