[jira] [Commented] (FLINK-5636) IO Metric for StreamTwoInputProcessor

[ASF GitHub Bot (JIRA)]

[ 
https://issues.apache.org/jira/browse/FLINK-5636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16018018#comment-16018018
 ] 

ASF GitHub Bot commented on FLINK-5636:
---

Github user asfgit closed the pull request at:

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


> 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)

[jira] [Commented] (FLINK-5636) IO Metric for StreamTwoInputProcessor

[ASF GitHub Bot (JIRA)]

[ 
https://issues.apache.org/jira/browse/FLINK-5636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017421#comment-16017421
 ] 

ASF GitHub Bot commented on FLINK-5636:
---

Github user zentol commented on the issue:

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


> 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)

[jira] [Commented] (FLINK-5636) IO Metric for StreamTwoInputProcessor

[ASF GitHub Bot (JIRA)]

[ 
https://issues.apache.org/jira/browse/FLINK-5636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017417#comment-16017417
 ] 

ASF GitHub Bot commented on FLINK-5636:
---

Github user rmetzger commented on the issue:

https://github.com/apache/flink/pull/3950
  
+1 to merge


> 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)

[jira] [Commented] (FLINK-5636) IO Metric for StreamTwoInputProcessor

[ASF GitHub Bot (JIRA)]

[ 
https://issues.apache.org/jira/browse/FLINK-5636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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 
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)

[jira] [Commented] (FLINK-5636) IO Metric for StreamTwoInputProcessor

[Robert Metzger (JIRA)]

[ 
https://issues.apache.org/jira/browse/FLINK-5636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013952#comment-16013952
 ] 

Robert Metzger commented on FLINK-5636:
---

I ran into the issue as well.

[~david.wang] are you still working on it?

> 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
>Reporter: david.wang
>Assignee: david.wang
>
> 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)

[jira] [Commented] (FLINK-5636) IO Metric for StreamTwoInputProcessor

[Chesnay Schepler (JIRA)]

[ 
https://issues.apache.org/jira/browse/FLINK-5636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15853760#comment-15853760
 ] 

Chesnay Schepler commented on FLINK-5636:
-

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

> IO Metric for StreamTwoInputProcessor
> -
>
> Key: FLINK-5636
> URL: https://issues.apache.org/jira/browse/FLINK-5636
> Project: Flink
>  Issue Type: Bug
>  Components: Metrics, Streaming
>Affects Versions: 1.2.0, 1.3.0
>Reporter: david.wang
>Assignee: david.wang
>
> 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)