[
https://issues.apache.org/jira/browse/FLINK-5380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15801802#comment-15801802
]
ASF GitHub Bot commented on FLINK-5380:
---------------------------------------
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/3068
[FLINK-5380] Fix task metrics reuse for single-operator chains
This PR fixes the chain end detection in the `StreamingJobGraphGenerator`,
which fixes the re-use of metrics for tasks consisting of only a single
operator, which fixes the display in the WebInterface.
I've also added a test to make sure that chain start and end are set
correctly. Before the fix, `assertTrue(sourceConfig.isChainEnd());` would have
failed.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/zentol/flink 5380_web_metrics
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/3068.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 #3068
----
commit bfd038d13b73816adb4dab1387b1f75ecf2f2bfc
Author: zentol <[email protected]>
Date: 2017-01-05T13:37:03Z
[FLINK-5380] Fix task metrics reuse for single-operator chains
----
> Number of outgoing records not reported in web interface
> --------------------------------------------------------
>
> Key: FLINK-5380
> URL: https://issues.apache.org/jira/browse/FLINK-5380
> Project: Flink
> Issue Type: Bug
> Components: Metrics, Streaming, Webfrontend
> Affects Versions: 1.2.0, 1.3.0
> Reporter: Robert Metzger
> Assignee: Chesnay Schepler
> Fix For: 1.2.0, 1.3.0
>
> Attachments: outRecordsNotreported.png
>
>
> The web frontend does not report any outgoing records in the web frontend.
> The amount of data in MB is reported correctly.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
