[flink] 04/05: [FLINK-22877][table] Remove outdated comments

[twalthr]

This is an automated email from the ASF dual-hosted git repository.

twalthr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit a55a67d2ff00602f794cf621e9971feeb5bfff77
Author: Timo Walther <twal...@apache.org>
AuthorDate: Mon Jun 7 11:31:40 2021 +0200

    [FLINK-22877][table] Remove outdated comments
---
 .../java/org/apache/flink/table/catalog/ConnectorCatalogTable.java     | 3 ---
 .../org/apache/flink/table/operations/TableSourceQueryOperation.java   | 1 -
 2 files changed, 4 deletions(-)

diff --git 
a/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/ConnectorCatalogTable.java
 
b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/ConnectorCatalogTable.java
index 2ed089f..96c4781 100644
--- 
a/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/ConnectorCatalogTable.java
+++ 
b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/ConnectorCatalogTable.java
@@ -51,9 +51,6 @@ import java.util.stream.Collectors;
 public class ConnectorCatalogTable<T1, T2> extends AbstractCatalogTable {
     private final TableSource<T1> tableSource;
     private final TableSink<T2> tableSink;
-    // Flag that tells if the tableSource/tableSink is 
BatchTableSource/BatchTableSink.
-    // NOTES: this should be false in BLINK planner, because BLINK planner 
always uses
-    // StreamTableSource.
     private final boolean isBatch;
 
     public static <T1> ConnectorCatalogTable<T1, ?> source(
diff --git 
a/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/TableSourceQueryOperation.java
 
b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/TableSourceQueryOperation.java
index bb79606..5eb3596 100644
--- 
a/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/TableSourceQueryOperation.java
+++ 
b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/TableSourceQueryOperation.java
@@ -37,7 +37,6 @@ import java.util.Map;
 public class TableSourceQueryOperation<T> implements QueryOperation {
 
     private final TableSource<T> tableSource;
-    // Flag that tells if the tableSource is BatchTableSource.
     private final boolean isBatch;
 
     public TableSourceQueryOperation(TableSource<T> tableSource, boolean 
isBatch) {