感谢回复、jar添加到lib下没重启服务、 自己S 13了；
不过又在PyFlink 应用UDF（在SQL应用udf函数）过程中遇到如下问题；把udf函数去掉，pyflink 又可以执行..
请问有遇到过嘛？谢谢~
---
Caused by: java.lang.RuntimeException: Failed to create stage bundle
factory! INFO:root:Initializing python harness:
Hi,
flink-connector-jdbc_2.11-1.11.1.jar
有添加在flink/lib下，只能保证在作业执行的时候，可以找到对应的class，在客户端提交的时候，会编译作业，从报错看，是客户端编译作业的时候找不到对应的class。
可以试试这里的方法：https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/python/table-api-users-guide/dependency_management.html#java-dependency
> 在
请教大佬们：
在执行pyflink过程中，报错 Could not read the user code wrapper:
org.apache.flink.connector.jdbc.table.JdbcRowDataInputFormat
..
Caused by: java.lang.ClassNotFoundException:
org.apache.flink.connector.jdbc.table.JdbcRowDataInputFormat
flink-connector-jdbc_2.11-1.11.1.jar 有添加在flink/lib下
有了解的大佬嘛、谢谢~
