[
https://issues.apache.org/jira/browse/FLINK-28570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17576212#comment-17576212
]
godfrey he edited comment on FLINK-28570 at 8/6/22 1:03 PM:
------------------------------------------------------------
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
was (Author: godfreyhe):
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)
