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

IO Metric for StreamTwoInputProcessor

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 1.2.0, 1.3.0, 1.4.0
    • Fix Version/s: 1.3.0, 1.4.0
    • Component/s: DataStream API, Metrics
    • Labels:
      None

      Description

      Unlike SteamInputProcessor, there is no IO metrics for StreamTwoInputProcessor. It is useful to make a stat for two input stream processor, like TPS, # of input records.

        Issue Links

          Activity

          Hide
          Zentol Chesnay Schepler added a comment -

          david.wang What's your progress on this issue?

          Show
          Zentol Chesnay Schepler added a comment - david.wang What's your progress on this issue?
          Hide
          rmetzger Robert Metzger added a comment -

          I ran into the issue as well.

          david.wang are you still working on it?

          Show
          rmetzger Robert Metzger added a comment - I ran into the issue as well. david.wang are you still working on it?
          Hide
          githubbot ASF GitHub Bot added a comment -

          GitHub user zentol opened a pull request:

          https://github.com/apache/flink/pull/3950

          FLINK-5636[metrics] Measure numRecordsIn in StreamTwoInputProcessor

          You can merge this pull request into a Git repository by running:

          $ git pull https://github.com/zentol/flink 5636_io_two

          Alternatively you can review and apply these changes as the patch at:

          https://github.com/apache/flink/pull/3950.patch

          To close this pull request, make a commit to your master/trunk branch
          with (at least) the following in the commit message:

          This closes #3950


          commit 3dce5126528bb6430d804febb37c97a175f181cc
          Author: zentol <chesnay@apache.org>
          Date: 2017-05-19T12:39:20Z

          FLINK-5636[metrics] Measure numRecordsIn in StreamTwoInputProcessor


          Show
          githubbot ASF GitHub Bot added a comment - GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/3950 FLINK-5636 [metrics] Measure numRecordsIn in StreamTwoInputProcessor You can merge this pull request into a Git repository by running: $ git pull https://github.com/zentol/flink 5636_io_two Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/3950.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3950 commit 3dce5126528bb6430d804febb37c97a175f181cc Author: zentol <chesnay@apache.org> Date: 2017-05-19T12:39:20Z FLINK-5636 [metrics] Measure numRecordsIn in StreamTwoInputProcessor
          Hide
          githubbot ASF GitHub Bot added a comment -

          Github user rmetzger commented on the issue:

          https://github.com/apache/flink/pull/3950

          +1 to merge

          Show
          githubbot ASF GitHub Bot added a comment - Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/3950 +1 to merge
          Hide
          githubbot ASF GitHub Bot added a comment -

          Github user zentol commented on the issue:

          https://github.com/apache/flink/pull/3950

          merging.

          Show
          githubbot ASF GitHub Bot added a comment - Github user zentol commented on the issue: https://github.com/apache/flink/pull/3950 merging.
          Hide
          githubbot ASF GitHub Bot added a comment -

          Github user asfgit closed the pull request at:

          https://github.com/apache/flink/pull/3950

          Show
          githubbot ASF GitHub Bot added a comment - Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3950
          Hide
          Zentol Chesnay Schepler added a comment -

          1.3: 54b88d71c78a670762e152b337c04a2e68e8481d
          1.4: 8ccaffe3d3f2472fc12fa138c45c0b67458ad2a2

          Show
          Zentol Chesnay Schepler added a comment - 1.3: 54b88d71c78a670762e152b337c04a2e68e8481d 1.4: 8ccaffe3d3f2472fc12fa138c45c0b67458ad2a2

            People

            • Assignee:
              Zentol Chesnay Schepler
              Reporter:
              david.wang david.wang
            • Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved:

                Development