The additional exceptions with the same error but on different files
Pyflink lib error :
java.lang.RuntimeException: An error occurred while copying the file.
at org.apache.flink.api.common.cache.DistributedCache.getFile(
DistributedCache.java:158)
at org.apache.flink.python.env.PythonDependencyI
Hi,
We are using flink-1.17.0 table API and RocksDB as backend to provide a
service to our users to run sql queries. The tables are created using the
avro schema and we also provide users to attach python udf as a plugin.
This plugin is downloaded at the time of building the table and we update
th
