This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 68d8c5b3bd8 [hotfix][docs] Update the versions of mongodb supported by
mongodb-connector
add dc25bcabb5a [FLINK-33182][table] Allow metadata columns in Ndu-analyze
with ChangelogNormalize
No new revisions were added by this update.
Summary of changes:
.../planner/connectors/DynamicSourceUtils.java | 11 +
.../StreamNonDeterministicUpdatePlanVisitor.java | 84 ++--
.../stream/StreamPhysicalTableSourceScan.scala | 17 +-
.../stream/StreamPhysicalTableSourceScanRule.scala | 16 +-
.../NonDeterministicUpdateAnalyzerTest.java | 27 ++
.../analyze/NonDeterministicUpdateAnalyzerTest.xml | 15 +
.../plan/stream/sql/NonDeterministicDagTest.xml | 428 +++++++++++++++------
.../plan/stream/sql/NonDeterministicDagTest.scala | 108 ++++++
8 files changed, 556 insertions(+), 150 deletions(-)
