[jira] [Created] (BEAM-10768) DataChannelTest.test_time_based_flush_grpc_data_channel flake

["Kyle Weaver (Jira)" <ji...@apache.org>]

Kyle Weaver created BEAM-10768:
----------------------------------

             Summary: 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


=================================== 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)