GaoMingMing comments

Results 2 comments of


                                            GaoMingMing

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

> 2021年6月24日15：19：39437 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] -关闭作业0d970cef027a3313d275d9e2bab697d6的JobManager连接。 > 2021年6月24日15：19：47348 INFO org.apache.flink。 runtime.taskexecutor.TaskExecutor [] -从资源管理器接收时隙要求6fd6d829bcc9a798a3c13f9301590f35作业a6bb348b05dff9e96b70677dc2e6a92d与领导者ID 00000000000000000000000000000000. > 2021年6月24日15：19：47348信息org.apache.flink.runtime.taskexecutor.TaskExecutor [] - 为 6fd6d829bcc9a798a3c13f9301590f35 分配的插槽。 > 2021-06-24 15:19:47,348 INFO org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService [] - 以作业作业进行a690db3d70d4d448888667b7d3d关注点48988886667db3d关注 >...

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

> 2021年6月24日15：19：39437 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] -关闭作业0d970cef027a3313d275d9e2bab697d6的JobManager连接。 > 2021年6：1月2944415 org.apache.flink.runtime.taskexecutor.TaskExecutor 。runtime.taskexecutor.TaskExecutor [] -从资源管理器接收时隙要求6fd6d829bcc9a798a3c13f9301590f35作业a6bb348b05dff9e96b70677dc2e6a92d与领导者ID 00000000000000000000000000000000. > 2021年6月24日15：19：47348信息org.apache.flink.runtime.taskexecutor.TaskExecutor [ ] -为6fd6d829bcc9a798a3c13f9301590f35分配的插槽。 > 2021年6月24日15：19：47348 INFO org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService [] -以作业作业进行a690db3d70d4d448888667b7d3d关注点48988886667db3d关注 > 2021-06-24 15:19:47,348 INFO org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService []...