Re: Issues using PyFlink

2023-05-14 Thread Dian Fu
Hi Jill, I suspect that the PyFlink isn't installed in the Python environment which is used to run the example. Could you share the complete command you used to execute the example: `./flink-1.17.0/bin/flink run -pyclientexec venv/bin/python3 --python flink-1.17.0/examples/python/ datastream/word_

Issues using PyFlink

2023-05-11 Thread Jill Cardamon
Hi! I'm new to Flink, and I have been trying to run a simple python flink script that consumes messages from Kafka as well as the examples locally with a few issues. 1. When I run the word count example using `./flink-1.17.0/bin/flink run --python flink-1.17.0/examples/python/datastream/word_coun