Flink对接pulsar作为数据源输出的sink应该如何编写? Flink对接pulsar作为数据源输出的sink应该如何编写?... 帅平 /大数据 /2024-04-11 /1 评论 /41 阅读
Flink对接pulsar作为数据源输入的source应该如何编写? Flink对接pulsar作为数据源输入的source应该如何编写?... 帅平 /大数据 /2024-04-11 /1 评论 /38 阅读
flink 1.18,paimon 0.8-SNAPSHOT版本,lookup join经常出现oom的情况,之前用0.7版本没有这个问题,请问如何优化? flink 1.18,paimon 0.8-SNAPSHOT版本,lookup join经常出现oom的情况,之前用0.7版本没有这个问题,请问如何优化?报错信息如下:2024-04-08 02:53:39j... 帅平 /大数据 /2024-04-08 /3 评论 /66 阅读
使用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 评论 /101 阅读
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 评论 /132 阅读
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 评论 /160 阅读
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 评论 /74 阅读
Dinky 实时计算平台系列(二十三)Dinky0.x版本升级到1.0版本的踩坑之路 最近Dinky1.0版本发布了,在这里详细记录下对应的踩坑之路。本文档会进行长期持续的更新。1)jdk问题这里我服务器安装的jdk的版本,但是启动的时候报错了,提示:Unrecognized VM option ... Rae /flink系列 /2024-03-20 /0 评论 /281 阅读