阿里云
-
flink1.18 Yarn Application 提交,有人遇见过?-[阿里云_云淘科技]
flink1.18 Yarn Application 提交,有人遇见过? 以下为热心网友提供的参考意见 这个问题可能是由于Flink在提交Yarn Application时,无法找…
-
Flink数据源是 mysql 和官网上的一样的?-[阿里云_云淘科技]
Flink数据源是 mysql 和官网上的一样的? 以下为热心网友提供的参考意见 第一,你去重写序列化类,第二在算子中处理 ,此回答整理自钉群“【③群】Apache Flink C…
-
Flink中keyed state 不keyby()的流, 怎么存储状态呢?-[阿里云_云淘科技]
Flink中keyed state can only be used on a ‘keyed stream’不keyby()的流, 怎么存储状态呢? 以下为…
-
flink的jobmanager内存总是持续升高直到宕机,这个是什么原因呀,有解决思路么?-[阿里云_云淘科技]
flink的jobmanager内存总是持续升高直到宕机,这个是什么原因呀,有解决思路么?应该是失败重启导致的使用了restart策略,但是内存一直升高这个问题不知道怎么样解决 以…
-
提交flink任务一直刷这个信息是什么情况?-[阿里云_云淘科技]
提交flink任务一直刷这个信息是什么情况?资源是充足的 以下为热心网友提供的参考意见 根据你提供的日志,看起来你的 Flink 作业在部署时超出了60秒的限制。这可能意味着资源不…
-
Flink如果我配置了最大连续失败数不为 1 那么如果我 ck 失败了 我这批数据会丢失吗?-[阿里云_云淘科技]
Flink中kafka 的精准一次 sink 如果我配置了最大连续失败数不为 1 那么如果我 ck 失败了 我这批数据会丢失吗? 以下为热心网友提供的参考意见 如果你配置了最大连续…
-
Flink给每张mysql的表都配置了一个server-id的范围,请问这种问题怎么排查?-[阿里云_云淘科技]
Flink给每张mysql的表都配置了一个server-id的范围,提交多个任务时,还是有一些任务失败,报错如图。请问这种问题怎么排查? 以下为热心网友提供的参考意见 要排查Fli…
-
Flink有没有排查或者解决问题的思路呢?-[阿里云_云淘科技]
Flink自定义的Source实现了RichParallelSourceFunction,并行时ctx.collect会阻塞,不报错,但一直不往下执行,请教下,有没有排查或者解决问…
-
Flink中间计算结果如果存到redis, 合适吗 , checkpoint 咋保证一致性呢 ?-[阿里云_云淘科技]
Flink中间计算结果如果存到redis, 合适吗 前辈们, checkpoint 咋保证一致性呢 ? 以下为热心网友提供的参考意见 将Flink的中间计算结果存储到Redis中是…
-
flink有没得重启flink 的时候提交的任务也一起重启了,但是提交的任务每的了?-[阿里云_云淘科技]
flink有没得重启flink 的时候提交的任务也一起重启了,现在是里面有好几个人任务,停电服务器停止了,然后自动启动flink,但是提交的任务每的了? 以下为热心网友提供的参考意…
-
flink 1.15.4 /tmp目录,看每天都会生成10多个flink-这个是什么情况呢?-[阿里云_云淘科技]
flink 1.15.4 /tmp目录,看每天都会生成10多个flink-table-planner_xxx.jar,这个是什么情况呢? 以下为热心网友提供的参考意见 这个现象可能…
-
flinksql的模式同步数据到doris?-[阿里云_云淘科技]
flinksql的模式同步数据到doris? 以下为热心网友提供的参考意见 要将Flink SQL的模式同步数据到Doris,可以按照以下步骤进行操作: 首先,确保你已经在Flin…