Details
-
Bug
-
Status: Resolved
-
P1
-
Resolution: Fixed
-
None
Description
=================================== FAILURES ===================================
___________ DataChannelTest.test_time_based_flush_grpc_data_channel ____________
[gw0] darwin – Python 3.7.8 /Users/runner/work/beam/beam/sdks/python/target/.tox/py37/bin/python
self = <apache_beam.runners.worker.data_plane_test.DataChannelTest testMethod=test_time_based_flush_grpc_data_channel>
def test_time_based_flush_grpc_data_channel(self):
> self._grpc_data_channel_test(True)
apache_beam/runners/worker/data_plane_test.py:44:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
apache_beam/runners/worker/data_plane_test.py:74: in _grpc_data_channel_test
data_channel_service, data_channel_client, time_based_flush)
apache_beam/runners/worker/data_plane_test.py:87: in _data_channel_test
self._data_channel_test_one_direction(client, server, time_based_flush)
apache_beam/runners/worker/data_plane_test.py:129: in _data_channel_test_one_direction
instruction_id='2', transform_id=transform_2, data=b'ghi')
E AssertionError: Lists differ: [inst[26 chars]id: "2"
E data: "ghi"
E , instruction_id: "2"
E tran[22 chars]ef"
E ] != [inst[26 chars]id: "1"
E data: "def"
E , instruction_id: "2"
E tran[22 chars]hi"
E ]
E
E First differing element 0:
E instruction_id: "2"
E transform_id: "2"
E data: "ghi"
E
E instruction_id: "2"
E transform_id: "1"
E data: "def"
E
E
E [instruction_id: "2"
E + transform_id: "1"
E + data: "def"
E + ,
E + instruction_id: "2"
E transform_id: "2"
E data: "ghi"
E - ,
E - instruction_id: "2"
E - transform_id: "1"
E - data: "def"
E ]
Attachments
Issue Links
- links to
