[ 
https://issues.apache.org/jira/browse/BEAM-11070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17223249#comment-17223249
 ] 

Brian Hulette commented on BEAM-11070:
--------------------------------------

Raised to P1 per jira priorities guide

Saw this here: 
https://ci-beam.apache.org/job/beam_PreCommit_Python_PVR_Flink_Commit/839/testReport/junit/apache_beam.runners.portability.flink_runner_test/FlinkRunnerTestStreaming/test_register_finalizations/

{code}
self = 
<apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming 
testMethod=test_register_finalizations>

    def test_register_finalizations(self):
      self.enable_commit = True
>     super(FlinkRunnerTest, self).test_register_finalizations()

apache_beam/runners/portability/flink_runner_test.py:449: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/runners/portability/fn_api_runner/fn_runner_test.py:854: in 
test_register_finalizations
    self.assertEqual(results, sorted(elements_list))
E   AssertionError: Lists differ: [] != ['1', '2']
E   
E   Second list contains 2 additional elements.
E   First extra element 0:
E   '1'
E   
E   - []
E   + ['1', '2']
{code}

> Portable FlinkRunnerTestStreaming.test_register_finalizations is flkay
> ----------------------------------------------------------------------
>
>                 Key: BEAM-11070
>                 URL: https://issues.apache.org/jira/browse/BEAM-11070
>             Project: Beam
>          Issue Type: Bug
>          Components: test-failures
>            Reporter: Boyuan Zhang
>            Assignee: Boyuan Zhang
>            Priority: P1
>
> The test is flaky owing to flink checkpoint configuration. We should be able 
> to tune the configuration to make the test reliable.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to