[ https://issues.apache.org/jira/browse/BEAM-7058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16816628#comment-16816628 ]
Thomas Weise commented on BEAM-7058: ------------------------------------ The test that I pointed to in the email thread should be sufficient to reproduce by adding a sleep time into the user code: [https://github.com/apache/beam/blob/d38645ae8758d834c3e819b715a66dd82c78f6d4/sdks/python/apache_beam/runners/portability/flink_runner_test.py#L181] It would be nice to assert that the metrics are indeed reported then. In the Flink runner bundles in streaming mode are by default 1000 elements or 1s. > Python SDK metric process_bundle_msecs reported as zero > ------------------------------------------------------- > > Key: BEAM-7058 > URL: https://issues.apache.org/jira/browse/BEAM-7058 > Project: Beam > Issue Type: Bug > Components: runner-flink, sdk-py-harness > Reporter: Thomas Weise > Assignee: Alex Amato > Priority: Major > Labels: portability-flink > > With the portable Flink runner, the metric is reported as 0, while the count > metric works as expected. > [https://lists.apache.org/thread.html/25eec8104bda6e4c71cc6c5e9864c335833c3ae2afe225d372479f30@%3Cdev.beam.apache.org%3E] > -- This message was sent by Atlassian JIRA (v7.6.3#76005)