flink-sql映射iotdb的序列有特殊字符,你们是怎么转换的? flink-sql映射iotdb的序列有特殊字符,你们是怎么转换的?这种形式的,有-解析不出来,会报错org.apache.flink.sql.parser.impl.ParseException: Encoun... Rae 大数据 2024-10-12 19 阅读 1 评论
请教一下 使用flinkcdc整库同步mysql到doris,报错: Caused by: java.lang.NoSuchMethodError 请教一下 使用flinkcdc整库同步mysql到doris,报错:Caused by: java.lang.NoSuchMethodError: io.debezium.connector.mysql.MyS... 帅平 大数据 2024-07-27 111 阅读 3 评论
请教一下,flink有没有什么参数可以设置等待 yarn 分配资源(yarn 队列资源完全饱和状态)的超时时间或者重试次数 请教一下,flink有没有什么参数可以设置等待 yarn 分配资源(yarn 队列资源完全饱和状态)的超时时间或者重试次数... 帅平 大数据 2024-06-20 112 阅读 1 评论
如果flink有个任务lookup join了doris里面的表,然后他一直报错重启,是不是会疯狂占用整个doris的资源? 请教个问题,如果flink有个任务lookup join了doris里面的表,然后他一直报错重启,是不是会疯狂占用整个doris的资源?这个有办法做资源隔离啥的嘛... 帅平 大数据 2024-05-10 207 阅读 2 评论
flink application模式找不到mysql包,请问是什么原因呢? 我目前在用的是dinky 1.01版本已经在lib,extends文件夹添加了mysql-connector-java-8.0.25.jar文件但是启动flink application模式,报下面的错误... 帅平 大数据 2024-04-25 276 阅读 1 评论
Flink对接pulsar作为数据源输入的source应该如何编写? Flink对接pulsar作为数据源输入的source应该如何编写?... 帅平 大数据 2024-04-11 234 阅读 1 评论
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 285 阅读 3 评论