zhijiang created FLINK-15914:
--------------------------------
Summary: 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
Reporter: zhijiang
Assignee: zhijiang
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)
