Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-15914

Miss the barrier alignment metric for the case of two inputs

    XMLWordPrintableJSON

    Details

      Description

      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.

        Attachments

          Activity

            People

            • Assignee:
              zjwang Zhijiang
              Reporter:
              zjwang Zhijiang
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved:

                Time Tracking

                Estimated:
                Original Estimate - Not Specified
                Not Specified
                Remaining:
                Remaining Estimate - 0h
                0h
                Logged:
                Time Spent - 1h
                1h