Abacn commented on issue #20979:
URL: https://github.com/apache/beam/issues/20979#issuecomment-1452594981
Another problem related to this issue is that running PeriodicSequence on
Flink runner, the pipeline first runs for ~1 minute but then will fail with
error
```
Traceback (most recent call last):
File ".../periodictest.py", line 82, in <module>
test0(p)
File ".../py38beam/lib/python3.8/site-packages/apache_beam/pipeline.py",
line 601, in __exit__
self.result.wait_until_finish()
File
"...py38beam/lib/python3.8/site-packages/apache_beam/runners/portability/portable_runner.py",
line 614, in wait_until_finish
raise self._runtime_exception
RuntimeError: Pipeline ...-6ce3c5fde435 failed in state FAILED:
java.util.concurrent.TimeoutException: Heartbeat of TaskManager with id
100.81.162.100:53640-99d457 timed out.
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
