[GitHub] [flink] danny0405 commented on a change in pull request #11985: [FLINK-16989][table] Support ScanTableSource in blink planner

2020-05-08 Thread GitBox
danny0405 commented on a change in pull request #11985: URL: https://github.com/apache/flink/pull/11985#discussion_r422006300 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/FlinkCalciteCatalogReader.java ## @@ -188,11

[GitHub] [flink] danny0405 commented on a change in pull request #11985: [FLINK-16989][table] Support ScanTableSource in blink planner

2020-05-08 Thread GitBox
danny0405 commented on a change in pull request #11985: URL: https://github.com/apache/flink/pull/11985#discussion_r422001068 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/schema/CatalogSourceTable.scala ## @@ -226,4

[GitHub] [flink] danny0405 commented on a change in pull request #11985: [FLINK-16989][table] Support ScanTableSource in blink planner

2020-05-08 Thread GitBox
danny0405 commented on a change in pull request #11985: URL: https://github.com/apache/flink/pull/11985#discussion_r421997440 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/FlinkCalciteCatalogReader.java ## @@ -188,11

[GitHub] [flink] danny0405 commented on a change in pull request #11985: [FLINK-16989][table] Support ScanTableSource in blink planner

2020-05-07 Thread GitBox
danny0405 commented on a change in pull request #11985: URL: https://github.com/apache/flink/pull/11985#discussion_r421915899 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/DynamicTableSourceITCase.scala ##

[GitHub] [flink] danny0405 commented on a change in pull request #11985: [FLINK-16989][table] Support ScanTableSource in blink planner

2020-05-07 Thread GitBox
danny0405 commented on a change in pull request #11985: URL: https://github.com/apache/flink/pull/11985#discussion_r421898493 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/logical/FlinkLogicalTableSourceScan.scala