[ 
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)

Reply via email to