问答 2024-05-17 来自:开发者社区

flink任务遇到The application contains no execute() 问题

flink任务我把处理函数从KeyedProcessFunction改成KeyedCoProcessFunction,增加了某个从kafka的输入,为什么部署到环境中就爆出“org.apache.flink.client.deployment.application.ApplicationExecutionException: The application contains no execut....

文章 2024-05-17 来自:开发者社区

实时计算 Flink版产品使用合集之brokers可以配置多个,但是只要第1个brokers挂了任务就挂了如何解决

问题一:有用 flink on zeppelin的吗? 有用 flink on zeppelin的吗? 参考回答: 可以使用Flink on Zeppelin来可视化Flink应用程序,并通过Zeppelin Notebook实现数据分析和挖掘,可以方便地快速部署和管理Flink应用程序。您可以查看以下链接了解如何安装和使用Flink on Zeppe...

实时计算 Flink版产品使用合集之brokers可以配置多个,但是只要第1个brokers挂了任务就挂了如何解决
文章 2024-05-17 来自:开发者社区

实时计算 Flink版产品使用合集之在进行全量拉取时,任务完成之后内存没有被完全释放如何解决

问题一:Flink CDC这里的brokers虽然可以配置多个,但是只要第1个brokers挂了,这怎么破? Flink CDC这里的brokers虽然可以配置多个,但是只要第1个brokers挂了,任务就挂了,这怎么破? ...

实时计算 Flink版产品使用合集之在进行全量拉取时,任务完成之后内存没有被完全释放如何解决
文章 2024-05-17 来自:开发者社区

实时计算 Flink版产品使用合集之新表启动后其他任务已经完成,而DAG图上的busy状态仍然为100,并且保留的task的backpressure为0,是什么导致的

问题一:Flink CDC我在配置文件分配了三个G 没提交任务是只占用了100m 现在已经增长到1.7G? Flink CDC我在配置文件分配了三个G 没提交任务是只占用了100m 全量阶段跑完后占用1.6G 然后就一直不动了。现在已经增长到1.7G? ...

实时计算 Flink版产品使用合集之新表启动后其他任务已经完成,而DAG图上的busy状态仍然为100,并且保留的task的backpressure为0,是什么导致的
文章 2024-05-17 来自:开发者社区

实时计算 Flink版产品使用合集之在指定 db.* 后添加表就重启任务如何解决

问题一:Flink CDC底层监听是不是用到flink定时任务还是啥? Flink CDC底层监听是不是用到flink定时任务还是啥? 参考回答: dbz的监听,debezium 关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/567538 问题二:flinkcd...

实时计算 Flink版产品使用合集之在指定 db.* 后添加表就重启任务如何解决
文章 2024-05-17 来自:开发者社区

实时计算 Flink版产品使用合集之将OceanBase的CDC数据导入到Flink SQL的任务的步骤是什么

问题一:Flink CDC将hive作为source表,为啥总是一提交就结束呢,有人碰到过么? Flink CDC将hive作为source表,为啥总是一提交就结束呢,有人碰到过么? 参考回答: Flink CDC将Hive作为source表,一提交就结束的问题可能有多种原因。首先,需要确认的是Flink作业的配置是否正确,例如是否正确指定了Flink...

实时计算 Flink版产品使用合集之将OceanBase的CDC数据导入到Flink SQL的任务的步骤是什么
文章 2024-05-17 来自:开发者社区

实时计算 Flink版产品使用合集之是否可以使用 DataStream API 或 Flink SQL 开发任务

问题一:Flink CDC用DataStream开发任务么? Flink CDC用DataStream开发任务么?Flink SQL模式和DataStream哪种效率高些?sink写的是自定义的吗?全量和增量的并行度是怎么判断修改的呢?我现在也在用flink做数据同步? 参考回答: 生产没用过flink sql不知道。我只是用flink作为同步工具,自...

文章 2024-05-17 来自:开发者社区

实时计算 Flink版产品使用合集之1.13版本上部署一个flink1.17为什么任务启动一直accepted状态yarn的,有什么排查方向吗资源什么的都是充足的

问题一:yarn上不能部署两个不同版本的flink客户端吗? yarn上不能部署两个不同版本的flink客户端吗? 这个状态一直这样 参考回答: YARN上确实不能同时部署两个不同版本的Fl...

实时计算 Flink版产品使用合集之1.13版本上部署一个flink1.17为什么任务启动一直accepted状态yarn的,有什么排查方向吗资源什么的都是充足的
文章 2024-05-17 来自:开发者社区

实时计算 Flink版产品使用合集之遇到的binlog文件短时间内增加很多导致的任务失败如何解决

问题一:Flink CDC把原始库删除了以后重新创建了一个名称相同的库来着消费最新的binlog就没啥事了? Flink CDC把原始库删除了以后重新创建了一个名称相同的库来着,消费最新的binlog就没啥事了 不过...

实时计算 Flink版产品使用合集之遇到的binlog文件短时间内增加很多导致的任务失败如何解决
文章 2024-05-17 来自:开发者社区

实时计算 Flink版产品使用合集之任务执行一周后,TaskManagers挂掉,是什么原因导致的

问题一:flinkCDC任务执行一周后,task managers就会挂掉,请问一般是什么情况呢? flinkCDC任务执行一周后,task managers就会挂掉,请问一般是什么情况呢?有什么办法去解决或者是内存调优的办法么? ...

实时计算 Flink版产品使用合集之任务执行一周后,TaskManagers挂掉,是什么原因导致的

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

产品推荐

阿里云实时计算Flink

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

+关注