This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 6f05439 [hotfix][connector/kafka] Add Kafka connector dependency in
Kafka E2E test module
add c1b2e42 [FLINK-25183][table] Optimize changelog normalize for the
managed table upsert mode
No new revisions were added by this update.
Summary of changes:
.../table/factories/TestManagedTableFactory.java | 56 ++++++++++++---
.../stream/StreamPhysicalChangelogNormalize.scala | 12 ++--
.../FlinkChangelogModeInferenceProgram.scala | 31 +++++---
.../stream/StreamPhysicalTableSourceScanRule.scala | 4 +-
.../physical/stream/ChangelogModeInferenceTest.xml | 82 ++++++++++++++++++++++
.../plan/metadata/FlinkRelMdHandlerTestBase.scala | 8 ++-
.../FlinkRelMdModifiedMonotonicityTest.scala | 3 +-
.../stream/ChangelogModeInferenceTest.scala | 81 +++++++++++++++++++++
8 files changed, 252 insertions(+), 25 deletions(-)
