Hi, I was wondering if this is something wrong with my PR <https://github.com/apache/beam/pull/12084> or an issue in master. Thanks for your help.
Seeing this in my PR's presubmit https://ci-beam.apache.org/job/beam_PreCommit_Python2_PVR_Flink_Commit/5382/ Logs <https://scans.gradle.com/s/7nu4katdr26bq/console-log/raw?task=:sdks:python:test-suites:portable:py2:flinkCompatibilityMatrixBatchLOOPBACK> ====================================================================== ERROR: test_external_transforms (__main__.FlinkRunnerTest) ---------------------------------------------------------------------- Traceback (most recent call last): ==================== Timed out after 60 seconds. ==================== File "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python2_PVR_Flink_Commit/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py", line 204, in test_external_transforms assert_that(res, equal_to([i for i in range(1, 10)])) # Thread: <Thread(read_grpc_client_inputs, started daemon 140197933086464)> File "apache_beam/pipeline.py", line 547, in __exit__ self.run().wait_until_finish() # Thread: <Thread(Thread-212, started daemon 140198486710016)> File "apache_beam/runners/portability/portable_runner.py", line 543, in wait_until_finish self._observe_state(message_thread) File "apache_beam/runners/portability/portable_runner.py", line 552, in _observe_state for state_response in self._state_stream: # Thread: <_Worker(Thread-110, started daemon 140197924693760)> File "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python2_PVR_Flink_Commit/src/build/gradleenv/1866363813/local/lib/python2.7/site-packages/grpc/_channel.py", line 413, in next return self._next() File "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python2_PVR_Flink_Commit/src/build/gradleenv/1866363813/local/lib/python2.7/site-packages/grpc/_channel.py", line 697, in _next # Thread: <_MainThread(MainThread, started 140200366741248)> _common.wait(self._state.condition.wait, _response_ready) File "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python2_PVR_Flink_Commit/src/build/gradleenv/1866363813/local/lib/python2.7/site-packages/grpc/_common.py", line 138, in wait _wait_once(wait_fn, MAXIMUM_WAIT_TIMEOUT, spin_cb) File "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python2_PVR_Flink_Commit/src/build/gradleenv/1866363813/local/lib/python2.7/site-packages/grpc/_common.py", line 103, in _wait_once wait_fn(timeout=timeout) # Thread: <Thread(read_state, started daemon 140198503495424)> File "/usr/lib/python2.7/threading.py", line 359, in wait _sleep(delay) File "apache_beam/runners/portability/portable_runner_test.py", line 82, in handler raise BaseException(msg) BaseException: Timed out after 60 seconds. # Thread: <_Worker(Thread-18, started daemon 140198537066240)> ------------------------------------ # Thread: <Thread(Thread-207, started daemon 140199451412224)> ---------------------------------- # Thread: <_Worker(Thread-19, started daemon 140198528673536)> Ran 82 tests in 461.409s FAILED (errors=1, skipped=15)
