|
|
|
FLINK-33183
|
FLINK-27849
Enable metadata columns in NduAnalyzer with retract if non-virtual
|
Unassigned
|
Timo Walther
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
FLINK-33182
|
FLINK-27849
Allow metadata columns in NduAnalyzer with ChangelogNormalize
|
lincoln lee
|
Timo Walther
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-31404
|
FLINK-27849
Support extracting all mapping of Calc node's input references
|
Jane Chan
|
Jane Chan
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-28743
|
FLINK-27849
Support validating the determinism for StreamPhysicalMatchRecognize
|
lincoln lee
|
lincoln lee
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-28738
|
FLINK-27849
[doc] Add a user doc about the correctness for non-deterministic updates
|
Unassigned
|
lincoln lee
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-28570
|
FLINK-27849
Introduces a StreamNonDeterministicPlanResolver to validate and try to solve (lookup join only) the non-deterministic updates problem which may cause wrong result or error
|
lincoln lee
|
lincoln lee
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-28568
|
FLINK-27849
Implements a new lookup join operator (sync mode only) with state to eliminate the non determinism
|
lincoln lee
|
lincoln lee
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-28566
|
FLINK-27849
Adds materialization support to eliminate the non determinism generated by lookup join node
|
Unassigned
|
lincoln lee
|
|
Closed |
Abandoned
|
|
|
|
|
|
|
|
FLINK-28536
|
FLINK-27849
Adds an internal postOptimize method for physical dag processing
|
Unassigned
|
lincoln lee
|
|
Closed |
Fixed
|
|
|
|
|