breeze1126

Results 4 comments of breeze1126

请教下，flink写入clinkhouse，在flink监控日志出现Cannot load user class: com.thorntree.bigdata.table.ClickHouseSinkFunction是我哪里编译出现问题了吗？

2021-06-24 15:19:39,437 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Close JobManager connection for job 0d970cef027a3313d275d9e2bab697d6. 2021-06-24 15:19:47,348 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Receive slot request 6fd6d829bcc9a798a3c13f9301590f35 for job a6bb348b05dff9e96b70677dc2e6a92d from resource manager with leader...

请教下，flink写入clinkhouse，在flink监控日志出现Cannot load user class: com.thorntree.bigdata.table.ClickHouseSinkFunction是我哪里编译出现问题了吗？

嗯嗯，好。我用的版本是flink1.12的，编译和部署都没有问题，就是把任务提交上flink之后出现的这个异常。那我再去检查一下环境变量看看。

请教下，flink写入clinkhouse，在flink监控日志出现Cannot load user class: com.thorntree.bigdata.table.ClickHouseSinkFunction是我哪里编译出现问题了吗？

> 嗯嗯，好。我用的版本是 flink1.12 的，编译和部署都没有问题，就是把任务提交上 flink 之后出现的这个异常。我再去检查一下环境启动器看看。

请教下，flink写入clinkhouse，在flink监控日志出现Cannot load user class: com.thorntree.bigdata.table.ClickHouseSinkFunction是我哪里编译出现问题了吗？

Caused by: org.apache.flink.table.api.ValidationException: One or more required options are missing. 这个需要麻烦检查一下 是不是少配置了什么