This is an automated email from the ASF dual-hosted git repository.
godfrey pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 412c45f [FLINK-23944][connector/pulsar] Enable
PulsarSourceITCase.testTaskManagerFailure after test framework was fixed.
add d93682c [FLINK-22603][table-planner] The digest can be produced by
SourceAbilitySpec
No new revisions were added by this update.
Summary of changes:
.../planner/connectors/DynamicSourceUtils.java | 3 +-
.../plan/abilities/source/FilterPushDownSpec.java | 21 +++++
.../plan/abilities/source/LimitPushDownSpec.java | 5 +
.../abilities/source/PartitionPushDownSpec.java | 8 ++
.../plan/abilities/source/ProjectPushDownSpec.java | 12 +++
.../plan/abilities/source/ReadingMetadataSpec.java | 5 +
.../plan/abilities/source/SourceAbilitySpec.java | 7 ++
.../plan/abilities/source/SourceWatermarkSpec.java | 5 +
.../abilities/source/WatermarkPushDownSpec.java | 16 ++++
.../nodes/exec/spec/TemporalTableSourceSpec.java | 2 +-
.../logical/PushFilterIntoSourceScanRuleBase.java | 27 +-----
.../logical/PushLimitIntoTableSourceScanRule.java | 5 +-
.../PushPartitionIntoTableSourceScanRule.java | 9 --
.../PushProjectIntoTableSourceScanRule.java | 32 +------
.../PushWatermarkIntoTableSourceScanRuleBase.java | 8 +-
.../table/planner/plan/nodes/FlinkRelNode.scala | 92 +-----------------
.../planner/plan/nodes/common/CommonCalc.scala | 19 +++-
.../nodes/physical/common/CommonPhysicalJoin.scala | 4 +-
.../physical/common/CommonPhysicalLookupJoin.scala | 19 ++--
.../stream/StreamPhysicalIntervalJoin.scala | 3 +-
.../stream/StreamPhysicalWatermarkAssigner.scala | 5 +-
.../physical/stream/StreamPhysicalWindowJoin.scala | 5 +-
.../planner/plan/schema/TableSourceTable.scala | 33 +++++--
.../table/planner/plan/utils/FlinkRexUtil.scala | 105 ++++++++++++++++++++-
.../table/planner/plan/utils/RelExplainUtil.scala | 5 +-
.../table/planner/plan/utils/WindowJoinUtil.scala | 3 +-
.../serde/TemporalTableSourceSpecSerdeTest.java | 18 ++--
.../PushFilterIntoTableSourceScanRuleTestBase.java | 11 +++
.../table/filesystem/FileSystemTableSourceTest.xml | 2 +-
.../testFilterPushDown.out | 4 +-
.../testWatermarkPushDown.out | 2 +-
.../PushFilterInCalcIntoTableSourceRuleTest.xml | 53 +++++++++--
...PushFilterIntoLegacyTableSourceScanRuleTest.xml | 37 ++++++++
.../PushFilterIntoTableSourceScanRuleTest.xml | 55 +++++++++--
.../PushWatermarkIntoTableSourceScanRuleTest.xml | 18 ++--
.../plan/stream/sql/FilterableSourceTest.xml | 18 ++--
.../plan/stream/sql/SourceWatermarkTest.xml | 18 ++--
.../planner/plan/stream/sql/TableScanTest.xml | 2 +-
.../planner/plan/metadata/MetadataTestUtil.scala | 21 +++--
39 files changed, 450 insertions(+), 267 deletions(-)
