感谢回复、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:
/opt/python36/lib/python3.6/site-packages/pyflink/fn_execution/beam/beam_boot.py
--id=1-1 --logging_endpoint=localhost:32926
--artifact_endpoint=localhost:27046 --provision_endpoint=localhost:39820
--control_endpoint=localhost:31631
Failed to set up logging handler, continuing without.
Traceback (most recent call last):
File
"/opt/python36/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker_main.py",
line 94, in main
fn_log_handler = FnApiLogRecordHandler(logging_service_descriptor)
File
"/opt/python36/lib/python3.6/site-packages/apache_beam/runners/worker/log_handler.py",
line 75, in __init__
grpc.channel_ready_future(ch).result(timeout=60)
File "/opt/python36/lib/python3.6/site-packages/grpc/_utilities.py", line
140, in result
self._block(timeout)
File "/opt/python36/lib/python3.6/site-packages/grpc/_utilities.py", line
86, in _block
raise grpc.FutureTimeoutError()
grpc.FutureTimeoutError
WARNING:apache_beam.runners.worker.sdk_worker_main:No session file found:
/tmp/staged/pickled_main_session. Functions defined in __main__ (interactive
session) may fail.
WARNING:apache_beam.options.pipeline_options:Discarding unparseable args:
['--options_id=0.0', '--app_name=AbstractPythonFunctionRunner']
ERROR:apache_beam.runners.worker.sdk_worker_main:Python sdk harness failed:
Traceback (most recent call last):
File
"/opt/python36/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker_main.py",
line 158, in main
sdk_pipeline_options.view_as(ProfilingOptions))).run()
File
"/opt/python36/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 162, in __init__
grpc.channel_ready_future(self._control_channel).result(timeout=60)
File "/opt/python36/lib/python3.6/site-packages/grpc/_utilities.py", line
140, in result
self._block(timeout)
File "/opt/python36/lib/python3.6/site-packages/grpc/_utilities.py", line
86, in _block
raise grpc.FutureTimeoutError()
grpc.FutureTimeoutError
Traceback (most recent call last):
File "/opt/python36/lib/python3.6/runpy.py", line 193, in
_run_module_as_main
"__main__", mod_spec)
File "/opt/python36/lib/python3.6/runpy.py", line 85, in _run_code
exec(code, run_globals)
File
"/opt/python36/lib/python3.6/site-packages/pyflink/fn_execution/beam/beam_sdk_worker_main.py",
line 29, in <module>
apache_beam.runners.worker.sdk_worker_main.main(sys.argv)
File
"/opt/python36/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker_main.py",
line 158, in main
sdk_pipeline_options.view_as(ProfilingOptions))).run()
File
"/opt/python36/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 162, in __init__
grpc.channel_ready_future(self._control_channel).result(timeout=60)
File "/opt/python36/lib/python3.6/site-packages/grpc/_utilities.py", line
140, in result
self._block(timeout)
File "/opt/python36/lib/python3.6/site-packages/grpc/_utilities.py", line
86, in _block
raise grpc.FutureTimeoutError()
grpc.FutureTimeoutError
-----------
t_env.sql_query("""
SELECT
colA ,
colB ,
colC ,
colD ,
colE ,
colF ,
colG ,
colH ,
train_and_predict(colA, colB, colC, colD, colE, colF, colG, colH) P
（去掉可以执行、加上报上面的错 0.0）
FROM
source
""").insert_into("print_table")
=========
--
Sent from: http://apache-flink.147419.n8.nabble.com/
