Zakelly Lan created FLINK-37206:
-----------------------------------
Summary: Initialization issue of batching timer service in async
state operators
Key: FLINK-37206
URL: https://issues.apache.org/jira/browse/FLINK-37206
Project: Flink
Issue Type: Bug
Components: Runtime / Async State Processing
Affects Versions: 2.0-preview
Reporter: Zakelly Lan
Assignee: Zakelly Lan
Fix For: 2.0.0
We have ship two abstract stream operators for async state processing, where a
async timer service (manager) is introduced. Actually these operators can run
in sync mode, this is especially the case for batch execution mode. Currently
there is an issue when initializing batching timer service in those operators.
We'll fix that to enable batch execution for operators with async state.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)