问答 2021-10-27 来自:开发者社区

FLink任务报MapState currently isn't supported异常

异常信息:org.apache.flink.util.StateMigrationException: The new serializer for a MapState requires state migration in order for the job to proceed. However, migration for MapState currently isn't support....

问答 2021-10-27 来自:开发者社区

Flink任务报StateMigrationException异常

报错信息:org.apache.flink.util.StateMigrationException: The new state serializer cannot be incompatible

问答 2021-10-27 来自:开发者社区

Flink任务报跳过当前checkpoint异常

报错信息:Received checkpoint barrier for checkpoint before completing current checkpoint . Skipping current checkpoint

问答 2021-10-27 来自:开发者社区

Flink任务启动报IOException异常

任务报错:java.io.IOException: Too many open file

问答 2021-10-27 来自:开发者社区

flink任务遇到akka超时异常

akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka://...]] after [10000 ms]

问答 2021-10-21 来自:开发者社区

Flink任务启动RuntimeException报错

启动Flink任务的时候报错Caused by: java.lang.RuntimeException: Couldn't deploy Yarn cluster,system times on machines may be out of sync

文章 2021-09-27 来自:开发者社区

如何迁移开源 Flink 任务到实时计算Flink版?实战手册来帮忙!

作为国内最早布局实时计算技术方向的企业之一,早在2016年阿里巴巴就已经开始大规模上线使用实时计算产品。阿里云实时计算Flink版(Alibaba Cloud Realtime Compute for Apache Flink,Powered by Ververica)是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统,由 Apache Flink 创始团队官方出品,....

如何迁移开源 Flink 任务到实时计算Flink版?实战手册来帮忙!
问答 2021-09-23 来自:开发者社区

我在使用flink读取savepoint里keystate数据时,大状态任务就卡住,加大资源也不管用

我在用flink 的state processor api修改savepoint里的keystate数据时,state数据量小就可以执行完,数据量大读取一部分数据后就一直running状态,不读新数据,加大资源并行度也不能解决,任务也不报错。

问答 2021-08-29 来自:开发者社区

自建的flink集群向ADB Mysql中写入数据时,由于写入任务的相互影响,导致背压过大,如何解决

ADB Mysql对于flink1.9有专有的flink sink jar包吗?我这边写入ADB Mysql时,由于写入任务的相互影响,在写入任务密集的时间段,flink任务的背压比较高,提高flink sink算子的并行度也并未出现缓解,使用的是自定义sink,德鲁伊连接池,Jdbc连接方式往ADB Mysql中进行写入的;想了解一下如何能消除flink任务的背压;

问答 2021-03-01 来自:开发者社区

flink任务如何在一个程序中添加多个sink或source?

flink任务如何在一个程序中添加多个sink或source?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注