流计算
-
DataWorks中flink任务跑了一半直重启是为什么?-[阿里云_云淘科技]
DataWorks中flink任务跑了一半直重启是为什么? 以下为热心网友提供的参考意见 根据您提供的错误信息,这可能是由于垃圾回收管理器在执行垃圾回收操作时被中断导致的。具体原因…
-
Hologres的mc 离线数据 和 Flink 的实时数据合并有好的方案吗?-[阿里云_云淘科技]
Hologres的mc 离线数据 和 Flink 的实时数据合并有好的方案吗, 还有 mc 同步 holo 有增量方案吗? 以下为热心网友提供的参考意见 Hologres与Flin…
-
Hologres账号里面没有用到Flink的产品,不知道是不是和dataworks的同步有关?-[阿里云_云淘科技]
Hologres账号里面没有用到Flink的产品,但用到了dataworks的同步。不知道是不是和dataworks的同步有关? 以下为热心网友提供的参考意见 Hologres 2…
-
Hologres分区表支持实时同步Binlog吗?-[阿里云_云淘科技]
Hologres分区表支持实时同步Binlog吗?对 flink 读取Hologres 分区表,现在现象是全量数据可以读取到,增量数据获取不到 以下为热心网友提供的参考意见 不支持…
-
请教一个Flink问题,如何转变为 DataStream<RowData>?-[阿里云_云淘科技]
请教一个Flink问题, 在不使用tabEnv的情况下,DataStream 如何转变为 DataStream? 以下为热心网友提供的参考意见 在不使用Table API的情况下,…
-
有没有测试过flink拉取kafka的单topic速度极限是多少?-[阿里云_云淘科技]
有没有大佬测试过flink拉取kafka的单topic速度极限是多少?我这边测的是20多M每秒,还能再提高吗?我现在是单topic单partition 以下为热心网友提供的参考意见…
-
flink任务 调整内存和cpu分配之后启动报错?-[阿里云_云淘科技]
flink任务 调整内存和cpu分配之后启动报错?Failed to rollback to checkpoint/savepoint Checkpoint Metadata. M…
-
请教一个Flink问题,基于springboot2.6.0构建的flink项目,该怎么解决呢?-[阿里云_云淘科技]
请教一个Flink问题,基于springboot2.6.0构建的flink项目,提交到flink环境报如下图所示错误,该怎么解决呢? 以下为热心网友提供的参考意见 org.myba…
-
Flink目前实时怎么验证数据结果的准确性呢?-[阿里云_云淘科技]
Flink目前实时怎么验证数据结果的准确性呢?比如统计七天的数据 离线抽前六天 实时跑今天的 怎么验证实时数据的准确性 以下为热心网友提供的参考意见 要验证Flink实时数据的准确…
-
Flink之前任务少mysql数据可以正常抽到doris ,任务超过20几就一直会报超时问题?-[阿里云_云淘科技]
Flink之前任务少mysql数据可以正常抽到doris ,任务超过20几就一直会报超时问题设置flinkcdc两个参数,也不行 以下为热心网友提供的参考意见 按照第一个为主的,你…
-
Flink我一个作业4000个并发度,jobmanager内存大概给多少?-[阿里云_云淘科技]
Flink我一个作业4000个并发度,jobmanager内存大概给多少? 以下为热心网友提供的参考意见 Flink作业的并发度和JobManager内存大小之间没有固定的关系,因…
-
flink cdc跑多个MySQL到doris任务,报错数据库连接超时,还有其他什么地方需要配置?-[阿里云_云淘科技]
flink cdc跑多个MySQL到doris任务,报错数据库连接超时,查看连接的数据库连接数及超时时间正常,请教大佬们还有其他什么地方需要配置? 以下为热心网友提供的参考意见 您…