[FLINK-31337] EmbeddedDataStreamBatchTests.test_keyed_co_broadcast_side_output

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 1.17.0, 1.16.1
• Fix Version/s: 1.17.0, 1.16.2
• Component/s: API / Python
• Labels: pull-request-available test-stability
• Assignee: Juntao Hu
• Reporter: Matthias Pohl
• Created: 06/Mar/23 09:39
• Updated: 06/Mar/23 15:41
• Resolved: 06/Mar/23 15:41

Description

Same build, multiple times:

• https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=46799&view=logs&j=9cada3cb-c1d3-5621-16da-0f718fb86602&t=c67e71ed-6451-5d26-8920-5a8cf9651901&l=24566
• https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=46799&view=logs&j=821b528f-1eed-5598-a3b4-7f748b13f261&t=6bb545dd-772d-5d8c-f258-f5085fba3295&l=24235
• https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=46799&view=logs&j=e92ecf6d-e207-5a42-7ff7-528ff0c5b259&t=40fc352e-9b4c-5fd8-363f-628f24b01ec2&l=24545
• https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=46799&view=logs&j=3e4dd1a2-fe2f-5e5d-a581-48087e718d53&t=b4612f28-e3b5-5853-8a8b-610ae894217a&l=24481
• https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=46799&view=logs&j=bf5e383b-9fd3-5f02-ca1c-8f788e2e76d3&t=85189c57-d8a0-5c9c-b61d-fc05cfac62cf&l=24757

Mar 04 01:21:35 pyflink/datastream/tests/test_data_stream.py:743: 
Mar 04 01:21:35 _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
Mar 04 01:21:35 pyflink/datastream/tests/test_data_stream.py:63: in assert_equals_sorted
Mar 04 01:21:35     self.assertEqual(expected, actual)
Mar 04 01:21:35 E   AssertionError: Lists differ: ['0', '1', '2', '4', '5', '5', '6', '6'] != ['0', '1', '2', '3', '5', '5', '6', '6']
Mar 04 01:21:35 E   
Mar 04 01:21:35 E   First differing element 3:
Mar 04 01:21:35 E   '4'
Mar 04 01:21:35 E   '3'
Mar 04 01:21:35 E   
Mar 04 01:21:35 E   - ['0', '1', '2', '4', '5', '5', '6', '6']
Mar 04 01:21:35 E   ?                  ^
Mar 04 01:21:35 E   
Mar 04 01:21:35 E   + ['0', '1', '2', '3', '5', '5', '6', '6']
Mar 04 01:21:35 E   ?   

Issue Links

• is caused by: FLINK-31185 Python BroadcastProcessFunction not support side output
• links to: GitHub Pull Request #22107