[GitHub] [beam] Abacn commented on issue #20979: Portable runners should be able to issue checkpoints to Splittable DoFn

["Abacn (via GitHub)" <gi...@apache.org>]

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: github-unsubscribe@beam.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org