[
https://issues.apache.org/jira/browse/FLINK-17012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17093561#comment-17093561
]
Piotr Nowojski edited comment on FLINK-17012 at 4/28/20, 6:33 PM:
------------------------------------------------------------------
Another question came to my mind. How should this be working with unaligned
checkpoints recovery? With unaligned checkpoints, tasks must be running and
processing records, while they will be still technically speaking during the
input unpsilling/recovery.
edit: maybe we would need an extra state for the unaligned checkpoints after
all? Or expose state change to `RUNNING` to `StreamTask`?
was (Author: pnowojski):
Another question came to my mind. How should this be working with unaligned
checkpoints recovery? With unaligned checkpoints, tasks must be running and
processing records, while they will be still technically speaking during the
input unpsilling/recovery.
> Expose stage of task initialization
> -----------------------------------
>
> Key: FLINK-17012
> URL: https://issues.apache.org/jira/browse/FLINK-17012
> Project: Flink
> Issue Type: Improvement
> Components: Runtime / Metrics, Runtime / Task
> Reporter: Wenlong Lyu
> Priority: Major
>
> Currently a task switches to running before fully initialized, does not take
> state initialization and operator initialization(#open ) in to account, which
> may take long time to finish. As a result, there would be a weird phenomenon
> that all tasks are running but throughput is 0.
> I think it could be good if we can expose the initialization stage of tasks.
> What to you think?
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
