Re: PyFlink DataStream API problem

2021-06-15 Thread Dian Fu
It seems that there is something wrong during starting up the Python process. Have you installed Python 3 and also PyFlink in the docker image? Besides, you could take a look at the log of TaskManager and to see whether there are logs about the reason why the Python process starts up failed. R

PyFlink DataStream API problem

2021-06-15 Thread László Ciople
Hello, I am experimenting with the Python DataStream API in Flink 1.13, in order to confirm that it is a viable fit for our needs, basically trying to prove that what can be done in the Java DataStream API also works in Python. During testing of a processing pipeline, I encountered a problem at the