You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/01/30 15:44:00 UTC

[jira] [Commented] (FLINK-37206) Initialization issue of batching timer service in async state operators

    [ https://issues.apache.org/jira/browse/FLINK-37206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17922411#comment-17922411 ] 

Zakelly Lan commented on FLINK-37206:
-------------------------------------

master: 822ac6495bf38756ab34b40dacf3a9bbee2c59e3

> 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
>            Priority: Major
>              Labels: pull-request-available
>             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)