[ https://issues.apache.org/jira/browse/FLINK-28570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
godfrey he closed FLINK-28570. ------------------------------ Resolution: Fixed Fixed in master: fd6c1cc96ce91bdeb0957b5dc26a663d0ba5b1d5: Introduces a StreamNonDeterministicPlanResolver to validate and try to solve (lookup join only) the non-deterministic updates problem which may cause wrong result or error fa3aa8f3759149af1b3e82a82945fa3eb0d667e0:Optimize upsertKey inference for lookup join and fix ConnectorCatalogTable lost pk on stream source a4189170dce89334796170c952b4928740400712: Extracts common attributes into StreamPhysicalGroupAggregateBase for all sub-classes 512e4e0f2defa8a1cb2d731462ff65f6fcffaaab:Introduces a base class StreamPhysicalGroupWindowAggregateBase for all related sub-classes 5daebae30b930db99955cd68b6538e6278df9874: Append upsertMaterialize info by a simpler way of overriding the explainTerms method for StreamPhysicalSink bca84305750275f6188539ccbed0796dc2c2d63b: Extends FlinkRelOptUtil to support print upsertKey info > Introduces a StreamNonDeterministicPlanResolver to validate and try to solve > (lookup join only) the non-deterministic updates problem which may cause > wrong result or error > --------------------------------------------------------------------------------------------------------------------------------------------------------------------------- > > Key: FLINK-28570 > URL: https://issues.apache.org/jira/browse/FLINK-28570 > Project: Flink > Issue Type: Sub-task > Components: Table SQL / Planner > Reporter: lincoln lee > Assignee: lincoln lee > Priority: Major > Labels: pull-request-available > Fix For: 1.16.0 > > -- This message was sent by Atlassian Jira (v8.20.10#820010)