Hi Andrew,
Sorry for the late reply. It seems that I misunderstood your description.
The script `pyflink-udf-runner.sh` you need to check exists in the `bin`
directory of the `pyflink` package installed by the python interpreter you
are using. You can execute the following command to find the path
Hi Xingbo,
That file does not exist on the file system.
Thanks,
Andrew
On Monday, 28 December 2020, Xingbo Huang wrote:
> Hi Andrew,
>
> According to the error, you can try to check the file permission of
> "/test/python-dist-78654584-bda6-4c76-8ef7-87b6fd256e4f/
> python-files/site-packages/s
Hi Andrew,
According to the error, you can try to check the file permission of
"/test/python-dist-78654584-bda6-4c76-8ef7-87b6fd256e4f/python-files/site-packages/site-packages/pyflink/bin/pyflink-udf-runner.sh"
Normally, the permission of this script would be
-rwxr-xr-x
Best,
Xingbo
Andrew Kram
Hi,
I am using Flink in Zeppelin and trying to execute a UDF defined in Python.
The problem is I keep getting the following permission denied error in the
log:
Caused by:
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.util.concurrent.UncheckedExecutionException:
java.io.IOException: Can
