?????? pyflink??py4j??????????????????????????java???? ??

[??????]

??????????????????????????????????????????????????????
>>> from pyflink.util.utils import add_jars_to_context_class_loader
>>> add_jars_to_context_class_loader(['file:///root/Test2.jar']) 
>>> from pyflink.java_gateway import get_gateway
>>> get_gateway().jvm.Test2.main()
Traceback (most recent call last):
&nbsp; File "<stdin&gt;", line 1, in <module&gt;
&nbsp; File 
"/root/qyq_f/flink-1.12.0/opt/python/pyflink.zip/pyflink/util/exceptions.py", 
line 191, in wrapped_call
TypeError: Could not found the Java class 'Test2.main'. The Java dependencies 
could be specified via command line argument '--jarfile' or the config option 
'pipeline.jars'

java code??
package Test2;
public class Test2 {
    public int add(int a, int b) {
        return a + b;
    }

    public static void main(String[] args) {
            int a = 1;
            int b = 2;
            Test2 t2=new Test2();
            int c=t2.add(a,b);
            System.out.print(c);
        }
}




------------------&nbsp;????????&nbsp;------------------
??????:                                                                         
                                               "user-zh"                        
                                                            
<weizhong0...@gmail.com&gt;;
????????:&nbsp;2021??2??5??(??????) ????6:01
??????:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

????:&nbsp;Re: pyflink??py4j??????????????????????????java???? ??



???????????????????????????????????????????????????????????????????List:
add_jars_to_context_class_loader(["file:///xxx <file:///xxx&gt;"])

&gt; ?? 2021??2??5????17:48???????? <389243...@qq.com&gt; ??????
&gt; 
&gt; ????????????
&gt; 
??????????flink1.12.0????????????????????????????????url??????????????pyfink??????????hdfs????kerberos??????????
&gt; 
&gt; 
&gt; 
&gt; 
&gt; ------------------ ???????? ------------------
&gt; ??????: "user-zh" <weizhong0...@gmail.com&gt;;
&gt; ????????: 2021??2??5??(??????) ????3:53
&gt; ??????: "user-zh"<user-zh@flink.apache.org&gt;;
&gt; ????: Re: pyflink??py4j??????????????????????????java???? ??
&gt; 
&gt; Hi,
&gt; 
&gt; ????????????????java????????jar??????????????????jar??, 
????pyflink????????util????????????????:
&gt; from pyflink.util.utils import add_jars_to_context_class_loader
&gt; add_jars_to_context_class_loader("file:///xxx <file:///xxx&gt;") # 
??????????url??????????
&gt; 
&gt; ????????????java gateway??????????:
&gt; from pyflink.java_gateway import get_gateway
&gt; get_gateway().jvm.your.class.name.main()
&gt; 
&gt; ????????util????????????????????????????????????????????pyflink????
&gt; 
&gt; &gt; ?? 2021??2??5????10:48???????? <389243...@qq.com&gt; ??????
&gt; &gt; 
&gt; &gt; ????????????java 
jvm????kerberos??????????pyflink??????????????????????????????????????????????????????????????????????
&gt; &gt; 
&gt; &gt; 
&gt; &gt; 
&gt; &gt; 
&gt; &gt; ------------------&amp;nbsp;????????&amp;nbsp;------------------
&gt; &gt; 
??????:&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 
"user-zh"&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 <hxbks...@gmail.com&amp;gt;;
&gt; &gt; ????????:&amp;nbsp;2021??2??5??(??????) ????10:35
&gt; &gt; ??????:&amp;nbsp;"user-zh"<user-zh@flink.apache.org&amp;gt;;
&gt; &gt; 
&gt; &gt; ????:&amp;nbsp;Re: pyflink??py4j??????????????????????????java???? ??
&gt; &gt; 
&gt; &gt; 
&gt; &gt; 
&gt; &gt; Hi,
&gt; &gt; 
&gt; &gt; 
??????????java????udfs??????????????register_java_function????create_java_temporary_function??????????java????udfs??????????????????[1]
&gt; &gt; 
&gt; &gt; [1]
&gt; &gt; 
https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/python/table-api-users-guide/udfs/python_udfs.html#scalar-functions
&gt; &gt; 
&gt; &gt; Best,
&gt; &gt; Xingbo
&gt; &gt; 
&gt; &gt; 
&gt; &gt; ?????? <389243...@qq.com&amp;gt; ??2021??2??4?????? ????5:53??????
&gt; &gt; 
&gt; &gt; &amp;gt; ????????????pyflink??py4j??????????????java???? ??
&gt; 
&gt;