Hey,
I'm trying to run a pipeline with the Python SDK that reads from Kafka.
I've started with a simple one that just reads messages and prints them to
the console. When running on Flink, I get the following error:
File "kafka_print.py", line 36, in run_kafka_pipeline
| 'Print to console' >> beam.Map(print))
File
"/Users/nir.gazit/.pyenv/versions/beam/lib/python3.7/site-packages/apache_beam/pipeline.py",
line 581, in __exit__
self.result.wait_until_finish()
File
"/Users/nir.gazit/.pyenv/versions/beam/lib/python3.7/site-packages/apache_beam/runners/portability/portable_runner.py",
line 608, in wait_until_finish
raise self._runtime_exception
Any idea why is that? Printing seems to work fine when the source is some
static PCollection.
Thanks!
Nir
