search

uncleguanghui / pyflink_learn

基于 PyFlink 的学习文档，通过一个个小实践，便于大家快速入手 PyFlink
269 stars 98 forks source link

t_env problem #21

Open msute opened 2 years ago

msute commented 2 years ago

大佬你好。我运行steam时候报这个错。我是python3.8。请问你有遇见过这个错误吗 File "/Users/rui/Documents/01181756gtu3/pyflink_learn-master/examples/5_online_machine_learning/stream.py", line 175, in t_env.register_function('train_and_predict', model) File "/Users/rui/GaiWork/vv/lib/python3.8/site-packages/pyflink/table/table_environment.py", line 1051, in register_function self._j_tenv.registerFunction(name, java_function) File "/Users/rui/GaiWork/vv/lib/python3.8/site-packages/py4j/java_gateway.py", line 1321, in call return_value = get_return_value( File "/Users/rui/GaiWork/vv/lib/python3.8/site-packages/pyflink/util/exceptions.py", line 146, in deco return f(*a, **kw) File "/Users/rui/GaiWork/vv/lib/python3.8/site-packages/py4j/protocol.py", line 326, in get_return_value raise Py4JJavaError( py4j.protocol.Py4JJavaError: An error occurred while calling o13.registerFunction.

msute commented 2 years ago

上个解决了 又碰到这个了 Unable to create a source for reading table 'default_catalog.default_database.source'

uncleguanghui commented 2 years ago

贴一下 source 的配置代码