问答 2023-05-14 来自:开发者社区

把flink任务注册成 微服务基于这个项目把source 改改应该就行了吧?

把flink任务注册成 微服务基于这个项目把source 改改应该就行了吧? https://github.com/intsmaze/flink-boot

问答 2023-05-14 来自:开发者社区

我想问一下各位大佬,Flink CDC任务异常失败,一直无法停止怎么办,手动cancel也不行?

问题1:我想问一下各位大佬,Flink CDC任务异常失败,一直无法停止怎么办,手动cancel也不行,我是自己部署的集群,今天凌晨1点异常失败,但是一直没有停下来,我手动cancel也停不下来,集群可以关,但是还有其它任务,stop也不行 问题2:是不是只能重启集群了吗,不是yarn部署的,独立集群,用zk做高可用,yarn部署的话就可以直接强制停止任务吗,强制停止taskmanager就好了

问答 2023-05-14 来自:开发者社区

请问flink如何配合log4j配置文件,让每条日志输出都能带上任务名称或者id呢?这个我加了起不起

问题1:请问flink如何配合log4j配置文件,让每条日志输出都能带上任务名称或者id呢?这个我加了起不起来 我是用的flink run 这种命令启动的 问题2:这个命令是启动flink时加的还是启动任务的时候加的呢?

问答 2023-05-14 来自:开发者社区

大家生产环境如何提交flink任务呀?

大家生产环境如何提交flink任务呀?

问答 2023-05-09 来自:开发者社区

Flink CDC中怎么通过rest api接口提交一个flink任务?

Flink CDC中怎么通过rest api接口提交一个flink任务?

问答 2023-05-09 来自:开发者社区

Flink CDC这个是为什么,报错的这个表不在这个任务里,在另一个任务。

Flink CDC这个是为什么,报错的这个表不在这个任务里,在另一个任务。Caused by: org.apache.flink.util.FlinkRuntimeException: Read split MySqlSnapshotSplit{tableId=dmc_darlink.sms_batch_rpt, splitId='dmc_darlink.sms_batch_rpt:140', ....

问答 2023-05-09 来自:开发者社区

麻烦问下这个flink任务无明显报错。但是任务挂了是有啥可能呀?

麻烦问下这个flink任务无明显报错。但是任务挂了是有啥可能呀?

问答 2023-05-06 来自:开发者社区

有没有大神知道Flink中在k8s集群上运行样例任务TopSpeedWindowing.jar为啥找

有没有大神知道Flink中在k8s集群上运行样例任务TopSpeedWindowing.jar为啥找不到jobmanager但是在jobmanager可以创建taskmanager,版本是1.14.6

问答 2023-05-06 来自:开发者社区

请问有人遇到过flink重启任务创建新的yarnApplicationId嘛

请问有人遇到过flink重启任务创建新的yarnApplicationId嘛

问答 2023-05-06 来自:开发者社区

有没有大佬知道flink任务运行一段时间后的kafka consumer就不消费了,kafka端显示

有没有大佬知道flink任务运行一段时间后的kafka consumer就不消费了,kafka端显示消息堆积,flink web界面也显示没有新的数据进来,整个程序也没有报错,也没有挂掉,用的是FlinkKafkaConsumer,这是为啥?能指出一下排查方向也行的,日志都看了也没发现啥原因,thread dump则是看不懂,用的process time,没有管水印时间,而且没有用到窗口,就是数....

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

产品推荐

阿里云实时计算Flink

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

+关注