你看看log文件里,有没有其他log,log文件位置:/Library/Frameworks/Python.framework/Versions/3.6/lib/python3.6/site-packages/pyflink/log/
从你贴的异常来看,感觉像是连HiveMetastore出问题了,没有连上,可以看看log文件里,能不能看到具体原因。
> 在 2020年9月3日,下午4:37,程龙 <13162790...@163.com> 写道:
>
> 完整日志乳如下:
>
>
>
> Traceback (most recent call last):
>
>
完整日志乳如下:
Traceback (most recent call last):
File
"/Users/bjhl/PycharmProjects/flink-example/com.baijiahulian/connecthive/HiveTest.py",
line 26, in
t_env.register_catalog("default", hive_catalog)
File
有更完整的log吗?
> 在 2020年9月3日,下午4:12,程龙 <13162790...@163.com> 写道:
>
> 使用hivecatalog连接 抱一下错误
>
>
>
>
> flink py4j.protocol.Py4JJavaError: An error occurred while calling
> o10.registerCatalog. : java.lang.NullPointerException
使用hivecatalog连接 抱一下错误
flink py4j.protocol.Py4JJavaError: An error occurred while calling
o10.registerCatalog. : java.lang.NullPointerException