Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-10768

DataChannelTest.test_time_based_flush_grpc_data_channel flake

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: P1
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: test-failures
    • Labels:

      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

            Activity

              People

              • Assignee:
                ibzib Kyle Weaver
                Reporter:
                ibzib Kyle Weaver
              • Votes:
                0 Vote for this issue
                Watchers:
                1 Start watching this issue

                Dates

                • Created:
                  Updated:

                  Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 5h
                  5h