You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "zhijiang (Jira)" <ji...@apache.org> on 2020/02/11 10:10:00 UTC
[jira] [Commented] (FLINK-15914) Miss the barrier alignment metric
for the case of two inputs
[ https://issues.apache.org/jira/browse/FLINK-15914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034320#comment-17034320 ]
zhijiang commented on FLINK-15914:
----------------------------------
Merged in master: 2a0555bc85e5256718e6b546ffa768a80386e892
> Miss the barrier alignment metric for the case of two inputs
> ------------------------------------------------------------
>
> Key: FLINK-15914
> URL: https://issues.apache.org/jira/browse/FLINK-15914
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Checkpointing, Runtime / Metrics
> Affects Versions: 1.10.0
> Reporter: zhijiang
> Assignee: zhijiang
> Priority: Blocker
> Labels: pull-request-available
> Fix For: 1.10.0
>
> Time Spent: 40m
> Remaining Estimate: 0h
>
> When the StreamTwoInputSelectableProcessor was introduced before, it was missing to add the barrier alignment metric in the constructor. But it does not cause problems then, because only StreamTwoInputProcessor works at that time.
> After StreamTwoInputProcessor is replaced by StreamTwoInputSelectableProcessor as now, this bug is exposed and we will not see the barrier alignment metric for the case of two inputs.
> The solution is to add this metric while constructing the current StreamTwoInputProcessor.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)