t_env problem

[msute]

大佬你好。我运行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]

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

[uncleguanghui]

贴一下 source 的配置代码