请问我有个Flink需求是我们写了一个Function,在哪看指标信息呢?

请问我有个Flink需求是我们写了一个Function,暂且叫RuleFuntion,这个是过规则的,然后一条数据循环过几千个规则,现在我想记录每个规则的耗时,然后存入到MySQL中,现在的问题是,如果我直接在Function中使用单例连接MySQL,定期写入MySQL的话,我觉得不够优雅我想试试使...

Flink cdc有什么方法可以获取到全量快照读取完成的信息吗?

Flink cdc有什么方法可以获取到全量快照读取完成的信息吗?

实时数据分析:使用Flink实时发现最热Github项目

1 课时 |
404 人已学 |
免费

实时数据接入:5分钟上手 Flink MySQL 连接器

1 课时 |
204 人已学 |
免费

大数据知识图谱系列—基于ELK+Flink日志全观测最佳实践

1 课时 |
174 人已学 |
免费
开发者课程背景图

Flink CDC里控制台频繁打印这些信息一般是因为什么,是正常现象还是异常现象?

Flink CDC里控制台频繁打印这些信息一般是因为什么,是正常现象还是异常现象?

Flink CDC里提交一个sql任务,如何在sql运行中,能查看日志任务?

Flink CDC里提交一个sql任务,如何在sql运行中,能查看日志任务?提交到yarn上,在yarn的web上能看到执行的sql吗?就是有很多任务会提交到yarn上,有个别任务占用的内存很大,我想定位到具体是执行的那一个sql任务?

Flink维度信息广播流比主流数据晚到 ,有没有好得解决方案?

Flink维度信息广播流比主流数据晚到 ,有没有好得解决方案?

Flink CDC里Flink postgreSQL CDC 位置信息是什么?

Flink CDC里Flink postgreSQL CDC 位置信息是什么? 后来看了一下源码发现offsetmap里面的数据都用到了,整体代表一种位置信息,现在不知道它的各个分片的offsetmap有何不同?

Flink CDC里mysql CDC是否可以基于binlog的位置信息启动?

Flink CDC里mysql CDC是否可以基于binlog的位置信息启动? 同步数据时是否可以把binlog的位置信息传输到sink端?

Flink CDC里通过savepoint恢复除了指定savepoint 路径还要啥?

Flink CDC里那flinkcdc通过savepoint恢复除了了指定savepoint 路径还需要指定啥?flink run -s /data/bigdata/flksavepoint/savepoint-8bf7c8-d01d1e73c7c2 通过手动保存的savepoint 恢复flink...

提交flink任务一直刷这个信息是什么情况?

提交flink任务一直刷这个信息是什么情况?资源是充足的

Flink CDC taskManager 一直再报下面信息,不知道是不是有什么问题?

Flink CDC taskManager 一直再报下面信息,不知道是不是有什么问题?一月 02, 2024 3:15:06 下午 com.github.shyiko.mysql.binlog.BinaryLogClient$5 run信息: threadExecutor is shut down,...

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

产品推荐

社区圈子

阿里云实时计算Flink
阿里云实时计算Flink
一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。
199201+人已加入
加入
相关电子书
更多
基于 Flink SQL + Paimon 构建流式湖仓新方
基于 Flink CDC 打造 企业级实时数据集成方案
李劲松|Flink Table Store 典型应用场景
立即下载 立即下载 立即下载