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

Sat, 06 Feb 2021 16:54:06 -0800 

????????????????????????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.Test2.main(None)
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.Test2.main'. The Java 
dependencies could be specified via command line argument '--jarfile' or the 
config option 'pipeline.jars'
&gt;&gt;&gt; get_gateway().jvm.Test2.main(None)
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'
&gt;&gt;&gt; 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'

????????main??????

&gt;&gt;&gt; get_gateway().jvm.Test2.main
<py4j.java_gateway.JavaPackage object at 0x7ff901d7efd0&gt;





------------------&nbsp;????????&nbsp;------------------
??????:                                                                         
                                               "user-zh"                        
                                                            
<weizhong0...@gmail.com&gt;;
????????:&nbsp;2021??2??5??(??????) ????7:06
??????:&nbsp;"??????"<389243...@qq.com&gt;;
????:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;
????:&nbsp;Re: pyflink??py4j??????????????????????????java???? ??



????????:
get_gateway().jvm.Test2.Test2.main(None)

&gt; ?? 2021??2??5????18:27???????? <389243...@qq.com&gt; ??????
&gt; 
&gt; ??????????????????????????????????????????????????????
&gt; &gt;&gt;&gt; from pyflink.util.utils import 
add_jars_to_context_class_loader
&gt; &gt;&gt;&gt; add_jars_to_context_class_loader(['file:///root/Test2.jar 
<file:///root/Test2.jar&gt;']) 
&gt; &gt;&gt;&gt; from pyflink.java_gateway import get_gateway
&gt; &gt;&gt;&gt; get_gateway().jvm.Test2.main()
&gt; Traceback (most recent call last):
&gt;&nbsp;&nbsp; File "<stdin&gt;", line 1, in <module&gt;
&gt;&nbsp;&nbsp; File 
"/root/qyq_f/flink-1.12.0/opt/python/pyflink.zip/pyflink/util/exceptions.py", 
line 191, in wrapped_call
&gt; 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'
&gt; java code??
&gt; package Test2;
&gt; public class Test2 {
&gt;&nbsp;&nbsp;&nbsp;&nbsp; public int add(int a, int b) {
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; return a + b;
&gt;&nbsp;&nbsp;&nbsp;&nbsp; }
&gt; 
&gt;&nbsp;&nbsp;&nbsp;&nbsp; public static void main(String[] args) {
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
int a = 1;
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
int b = 2;
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
Test2 t2=new Test2();
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
int c=t2.add(a,b);
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
System.out.print(c);
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }
&gt; }
&gt; 
&gt; 
&gt; ------------------ ???????? ------------------
&gt; ??????:&nbsp; "user-zh" <weizhong0...@gmail.com 
<mailto:weizhong0...@gmail.com&gt;&gt;;
&gt; ????????: 2021??2??5??(??????) ????6:01
&gt; ??????: "user-zh"<user-zh@flink.apache.org 
<mailto:user-zh@flink.apache.org&gt;&gt;;
&gt; ????: Re: pyflink??py4j??????????????????????????java???? ??
&gt; 
&gt; ???????????????????????????????????????????????????????????????????List:
&gt; add_jars_to_context_class_loader(["file:///xxx <file:///xxx&gt; 
<file:///xxx <file:///xxx&gt;&gt;"])
&gt; 
&gt; &gt; ?? 2021??2??5????17:48???????? <389243...@qq.com&gt; ??????
&gt; &gt; 
&gt; &gt; ????????????
&gt; &gt; 
??????????flink1.12.0????????????????????????????????url??????????????pyfink??????????hdfs????kerberos??????????
&gt; &gt; 
&gt; &gt; 
&gt; &gt; 
&gt; &gt; 
&gt; &gt; ------------------ ???????? ------------------
&gt; &gt; ??????: "user-zh" <weizhong0...@gmail.com&gt;;
&gt; &gt; ????????: 2021??2??5??(??????) ????3:53
&gt; &gt; ??????: "user-zh"<user-zh@flink.apache.org&gt;;
&gt; &gt; ????: Re: pyflink??py4j??????????????????????????java???? ??
&gt; &gt; 
&gt; &gt; Hi,
&gt; &gt; 
&gt; &gt; ????????????????java????????jar??????????????????jar??, 
????pyflink????????util????????????????:
&gt; &gt; from pyflink.util.utils import add_jars_to_context_class_loader
&gt; &gt; add_jars_to_context_class_loader("file:///xxx <file:///xxx&gt;") # 
??????????url??????????
&gt; &gt; 
&gt; &gt; ????????????java gateway??????????:
&gt; &gt; from pyflink.java_gateway import get_gateway
&gt; &gt; get_gateway().jvm.your.class.name.main()
&gt; &gt; 
&gt; &gt; ????????util????????????????????????????????????????????pyflink????
&gt; &gt; 
&gt; &gt; &gt; ?? 2021??2??5????10:48???????? <389243...@qq.com&gt; ??????
&gt; &gt; &gt; 
&gt; &gt; &gt; ????????????java 
jvm????kerberos??????????pyflink??????????????????????????????????????????????????????????????????????
&gt; &gt; &gt; 
&gt; &gt; &gt; 
&gt; &gt; &gt; 
&gt; &gt; &gt; 
&gt; &gt; &gt; ------------------&amp;nbsp;????????&amp;nbsp;------------------
&gt; &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 <mailto:hxbks...@gmail.com&gt;&amp;gt;;
&gt; &gt; &gt; ????????:&amp;nbsp;2021??2??5??(??????) ????10:35
&gt; &gt; &gt; ??????:&amp;nbsp;"user-zh"<user-zh@flink.apache.org 
<mailto:user-zh@flink.apache.org&gt;&amp;gt;;
&gt; &gt; &gt; 
&gt; &gt; &gt; ????:&amp;nbsp;Re: 
pyflink??py4j??????????????????????????java???? ??
&gt; &gt; &gt; 
&gt; &gt; &gt; 
&gt; &gt; &gt; 
&gt; &gt; &gt; Hi,
&gt; &gt; &gt; 
&gt; &gt; &gt; 
??????????java????udfs??????????????register_java_function????create_java_temporary_function??????????java????udfs??????????????????[1]
&gt; &gt; &gt; 
&gt; &gt; &gt; [1]
&gt; &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
 
<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; 
&gt; &gt; &gt; Best,
&gt; &gt; &gt; Xingbo
&gt; &gt; &gt; 
&gt; &gt; &gt; 
&gt; &gt; &gt; ?????? <389243...@qq.com <mailto:389243...@qq.com&gt;&amp;gt; 
??2021??2??4?????? ????5:53??????
&gt; &gt; &gt; 
&gt; &gt; &gt; &amp;gt; ????????????pyflink??py4j??????????????java???? ??
&gt; &gt; 
&gt; &gt;

回复