-
Notifications
You must be signed in to change notification settings - Fork 1.7k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[Question][Module Name] 使用ClickHouse Source时报两种错误 #1449
Comments
I will solve the first problem, the second please recheck the script configuration or update the latest code |
Thank you very much! The second problem has been solved after I updated the latest code! |
Search before asking
I had searched in the issues and found no similar question.
I had googled my question but i didn't get any help.
I had read the documentation: ChunJun doc but it didn't help me.
Description
官网提供的json文件参数选项中,ClickHouse Source有一个选项叫做“CustomSql”,这是一个非必要选项。我发现无论是否使用添加这个选项,都会报错,而且报的错误不一样。
运行环境说明:
操作系统:Ubuntu 16.04.7 LTS
jdk版本:jdk1.8
chunjun版本:1.12.7版本(最新版)
flink版本:1.13.5或1.12.7(更换这两个版本,均报一样的错误,说明跟flink版本无关)
ClickHouse版本:21.8.12.29
hive版本:2.3.9
情景一:json文件中ClickHouse Source一栏中不添加CustomSql选项
json文件如下:
这种情况下的报错:(空指针)
可以正常提交到flink集群中运行,但是运行了一段时间之后发现报空指针异常。此时去查看hive,发现“HOS_4000”这张hive表确实自动生成了,但是并没有同步到ClickHouse的数据,是个空表。
报错信息:
情景二:json文件中ClickHouse Source一栏中添加上CustomSql选项
json文件如下:
这种情况下的报错:
一旦添加上CustomSql选项之后,我发现问题变的更严重,任务甚至无法提交到flink Standalone集群中,就直接在本地控制台报错。
报错信息:
Code of Conduct
The text was updated successfully, but these errors were encountered: