Re: pyflink 1.11.1 调用包含第三方依赖库的udf时报错

2020-11-23 文章 Xingbo Huang
Hi, 你可以帖下taskmanager的日志吗,这个日志只能看到启动Python进程的时候挂掉了,其他信息看不到。 Best, Xingbo fengmuqi...@ruqimobility.com 于2020年11月23日周一 下午4:11写道: > hi. > pyflink 1.11.1 调用包含第三方依赖库的udf时报错 : > > 运行环境: > windows10 > python==3.7.9 > apache-flink==1.11.1 > apache-beam==2.19.0 > > udf 依赖第

pyflink 1.11.1 调用包含第三方依赖库的udf时报错

2020-11-23 文章 fengmuqi...@ruqimobility.com
hi. pyflink 1.11.1 调用包含第三方依赖库的udf时报错 : 运行环境: windows10 python==3.7.9 apache-flink==1.11.1 apache-beam==2.19.0 udf 依赖第三方库: h3==3.7.0 pytest 通过。 运行时报错,报错信息如下 2020-11-23 14:20:51,656 WARN org.apache.flink.runtime.taskmanager.Task [] - Source: TableSourceScan(table