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

[??????]

????????????
??????????flink1.12.0????????????????????????????????url??????????????pyfink??????????hdfs????kerberos??????????







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

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



Hi,

????????????????java????????jar??????????????????jar??, 
????pyflink????????util????????????????:
from pyflink.util.utils import add_jars_to_context_class_loader
add_jars_to_context_class_loader("file:///xxx <file:///xxx&gt;") # 
??????????url??????????

????????????java gateway??????????:
from pyflink.java_gateway import get_gateway
get_gateway().jvm.your.class.name.main()

????????util????????????????????????????????????????????pyflink????

&gt; ?? 2021??2??5????10:48???????? <389243...@qq.com&gt; ??????
&gt; 
&gt; ????????????java 
jvm????kerberos??????????pyflink??????????????????????????????????????????????????????????????????????
&gt; 
&gt; 
&gt; 
&gt; 
&gt; ------------------&amp;nbsp;????????&amp;nbsp;------------------
&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; ????????:&amp;nbsp;2021??2??5??(??????) ????10:35
&gt; ??????:&amp;nbsp;"user-zh"<user-zh@flink.apache.org&amp;gt;;
&gt; 
&gt; ????:&amp;nbsp;Re: pyflink??py4j??????????????????????????java???? ??
&gt; 
&gt; 
&gt; 
&gt; Hi,
&gt; 
&gt; 
??????????java????udfs??????????????register_java_function????create_java_temporary_function??????????java????udfs??????????????????[1]
&gt; 
&gt; [1]
&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; Best,
&gt; Xingbo
&gt; 
&gt; 
&gt; ?????? <389243...@qq.com&amp;gt; ??2021??2??4?????? ????5:53??????
&gt; 
&gt; &amp;gt; ????????????pyflink??py4j??????????????java???? ??