Hi 你好,
只看目前的报错看不出问题来，请问能贴出出错部分的job源码吗？
> 在 2020年11月17日，16:58，whh_960101 写道：
>
> Hi，各位大佬，pyflink 1.11 将pyflink作业提交到yarn集群运行，作业在将处理后的main_table
> insert到sink端的kafka时报错File "/home/cdh272705/poc/T24_parse.py", line 179, in
> from_kafka_to_oracle_demo
>
>
Hi，各位大佬，pyflink 1.11 将pyflink作业提交到yarn集群运行，作业在将处理后的main_table
insert到sink端的kafka时报错File "/home/cdh272705/poc/T24_parse.py", line 179, in
from_kafka_to_oracle_demo
main_table.execute_insert("sink")#.get_job_client().get_job_execution_result().result()
File
看起来是的，找不到JAVA_HOME，显式export一下JAVA_HOME试试？
> 在 2020年11月13日，下午5:06，whh_960101 写道：
>
> Hi，各位大佬， pyflink 1.11 运行pyflink作业时报错pyflink/pyfink_gateway_server.py 193行
> lauch_gateway_server_process()217行 return Popen（）FileNotFoundError： [Error 2]
> No such file or directory: 'java'
Hi，各位大佬，pyflink 1.11 运行pyflink作业时报错pyflink/pyfink_gateway_server.py 193行
lauch_gateway_server_process()217行 return Popen（）FileNotFoundError： [Error 2]
No such file or directory: 'java' : 'java'感觉像找不到java路径还是什么意思，java：java没看懂 ，该怎么解决
