使用dinky编写flinksql把数据同步到elasticsearch中报错,提示:org.apache.flink.table.types.logical.utils.LogicalTypeChe 使用dinky编写flinksql把数据同步到elasticsearch中报错,提示:Caused by: org.apache.flink.table.api.ValidationException: Unab... 帅平 /大数据 /2024-03-20 /2 评论 /161 阅读
Dinky运行flink sql任务报错,提示:Cannot discover a connector using option: 'connector'='elasticsearch-7' Dinky运行flink sql任务报错,提示:Caused by: org.apache.flink.table.api.ValidationException: Could not find any fac... 帅平 /大数据 /2024-03-20 /1 评论 /180 阅读
Dinky运行flink sql任务报错,提示:Could not find any factory for identifier 'mysql-cdc' Dinky运行flink sql任务报错,提示:Caused by: org.apache.flink.table.api.ValidationException: Could not find any fact... 帅平 /面试刷题 /2024-03-20 /1 评论 /205 阅读
Dinky数据开发模块的flink sql编写注释用什么格式? Dinky数据开发模块的flink sql编写注释用什么格式?我使用#和//都会报错。... 帅平 /大数据 /2024-03-20 /1 评论 /81 阅读
Dinky执行flink sql报错:Multiple factories for identifier 'default' that implement Dinky执行flink sql报错,提示如下:Caused by: org.apache.flink.table.api.ValidationException: Multiple factories for... 帅平 /大数据 /2024-03-20 /1 评论 /126 阅读
Dinky 实时计算平台系列(二十三)Dinky0.x版本升级到1.0版本的踩坑之路 最近Dinky1.0版本发布了,在这里详细记录下对应的踩坑之路。本文档会进行长期持续的更新。1)jdk问题这里我服务器安装的jdk的版本,但是启动的时候报错了,提示:Unrecognized VM option ... Rae /flink系列 /2024-03-20 /0 评论 /363 阅读
Dinky1.0版本部署的时候启动后无法访问,应该是启动出错了,但是没有生成logs文件,如何排查 部署dinky1.0的时候,执行启动命令后显示成功了,如下图:但是却无法访问,使用jps查看,竟然没启动起来,如下图:想要查看日志log,但是dinky的目录里面没有logs文件夹,如下图:请... 帅平 /大数据 /2024-03-19 /1 评论 /83 阅读
Dinky报错少了jdbc 传递connector,我应该在什么地方加一下呢? 请教个问题,我dinky0.75本地调试,整库同步功能,从mysql到mysql,sink用的jdbc形式,报错少了jdbc 传递connector,我应该在什么地方加一下呢?... 帅平 /大数据 /2024-01-19 /1 评论 /146 阅读