This is an automated email from the ASF dual-hosted git repository. kurt pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from 87f84e0 [hotfix][javadocs] Fix typo add cbf7b76 [FLINK-12399][table-planner] Check the table source digest changed after project/filter had been pushed down into it. No new revisions were added by this update. Summary of changes: docs/dev/table/sourceSinks.md | 8 +- docs/dev/table/sourceSinks.zh.md | 8 +- .../flink/addons/hbase/HBaseTableSource.java | 6 +- .../java/org/apache/flink/orc/OrcTableSource.java | 9 +- .../flink/formats/parquet/ParquetTableSource.java | 4 +- .../PushFilterIntoTableSourceScanRule.scala | 13 ++- .../PushPartitionIntoTableSourceScanRule.scala | 8 +- .../PushProjectIntoTableSourceScanRule.scala | 16 ++- .../planner/plan/batch/sql/TableSourceTest.xml | 36 +++---- .../PushFilterIntoTableSourceScanRuleTest.xml | 32 +++--- .../planner/plan/stream/sql/TableSourceTest.xml | 36 +++---- .../table/planner/utils/testTableSources.scala | 3 +- .../PushFilterIntoTableSourceScanRule.scala | 8 ++ .../PushProjectIntoTableSourceScanRule.scala | 15 ++- .../apache/flink/table/api/TableSourceTest.scala | 21 +++- .../validation/TableSourceValidationTest.scala | 72 +++++++++++++ .../table/utils/TestFilterableTableSource.scala | 118 ++++++++++++++++++--- .../flink/table/utils/testTableSources.scala | 62 ++++++++++- 18 files changed, 379 insertions(+), 96 deletions(-) create mode 100644 flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/stream/table/validation/TableSourceValidationTest.scala