[
https://issues.apache.org/jira/browse/BEAM-10768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kyle Weaver updated BEAM-10768:
-------------------------------
Fix Version/s: Not applicable
Resolution: Fixed
Status: Resolved (was: Resolved)
> DataChannelTest.test_time_based_flush_grpc_data_channel flake
> -------------------------------------------------------------
>
> Key: BEAM-10768
> URL: https://issues.apache.org/jira/browse/BEAM-10768
> Project: Beam
> Issue Type: Bug
> Components: test-failures
> Reporter: Kyle Weaver
> Assignee: Kyle Weaver
> Priority: P1
> Labels: flaky-test
> Fix For: Not applicable
>
> Time Spent: 5h
> Remaining Estimate: 0h
>
> =================================== 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 ]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
