[
https://issues.apache.org/jira/browse/FLINK-5636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16017339#comment-16017339
]
ASF GitHub Bot commented on FLINK-5636:
---------------------------------------
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 <[email protected]>
Date: 2017-05-19T12:39:20Z
[FLINK-5636][metrics] Measure numRecordsIn in StreamTwoInputProcessor
----
> IO Metric for StreamTwoInputProcessor
> -------------------------------------
>
> Key: FLINK-5636
> URL: https://issues.apache.org/jira/browse/FLINK-5636
> Project: Flink
> Issue Type: Bug
> Components: DataStream API, Metrics
> Affects Versions: 1.2.0, 1.3.0, 1.4.0
> Reporter: david.wang
> Assignee: Chesnay Schepler
>
> 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.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
