You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by ku...@apache.org on 2019/10/17 16:25:03 UTC

[flink] branch master updated (87f84e0 -> cbf7b76)

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