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

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

     [ https://issues.apache.org/jira/browse/BEAM-10768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Kyle Weaver updated BEAM-10768:
-------------------------------
    Status: Resolved  (was: Open)

> 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
>          Time Spent: 4h 20m
>  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)