Re: Pyflink 1.10.0 issue on cluster

Hi, And I've got another question. If I use user-defined function in pyflink, which only depends library A. And what the flink does is using the udf in tables. Does that mean I only need to install library A on the slaves? -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.na

Re: Pyflink 1.10.0 issue on cluster

Hi, Xingbo Thanks for your reply. So the point is that simply link the source or the sink to the master's local file system will cause the error that the slaves cannot read the source/sink files? Thus the simplest solution is to make sure that slaves have access to the master's local filesystem (by

Pyflink 1.10.0 issue on cluster

'm coding with pyflink 1.10.0 and building cluster with flink 1.10.0 I define the source and the sink as following: When I run this code only on master, it's OK. When I run this code o