Wang Qilong created FLINK-36942:
-----------------------------------
Summary: Unable to trigger onEventTime() when using the async
state API in RowTimestamportOperator
Key: FLINK-36942
URL: https://issues.apache.org/jira/browse/FLINK-36942
Project: Flink
Issue Type: Bug
Components: Table SQL / Runtime
Affects Versions: 2.0.0
Reporter: Wang Qilong
When I use the async state API in RowTimestamportOperator and inherit it from
AbstractAsyncStateStreamOperator, I cannot trigger onEventTime() when the timer
expires
Regarding how to reproduce:
in https://github.com/Au-Miner/flink/tree/RowTimeSortOperator
And execute the tests in RowTimestamportOperatorTest
I think this is a very strange bug because it can be triggered smoothly in
windowJoinOperator, but cannot be implemented in RowTimestamportOperator
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
