文章 2024-08-29 来自:开发者社区

实时计算 Flink版产品使用问题之运行后,怎么进行监控和报警

问题一:Flink CDC里mongo cdc从指定昨天开始戳消费,为什么消费20分钟了还没消费到数据? Flink CDC里mongo cdc从指定昨天开始戳消费,消费20分钟了还没消费到数据,这个是因为oplog太大了么? ...

实时计算 Flink版产品使用问题之运行后,怎么进行监控和报警
文章 2024-08-26 来自:开发者社区

联通实时计算平台问题之监控Kafka集群的断传和积压情况要如何操作

问题一:如何通过监控来定位和处理Flink作业中的反压问题? 如何通过监控来定位和处理Flink作业中的反压问题? 参考回答: 通过监控算子input channel的使用率来定位每个算子产生的反压。例如,当发现某个算子的input channel使用率持续高位时,说明该算子产生了反压,需要进一步定位到具体算子并排查原因,以保证系统的低延迟运行。 ...

联通实时计算平台问题之监控Kafka集群的断传和积压情况要如何操作
文章 2024-08-19 来自:开发者社区

实时计算 Flink版产品使用问题之怎么使用Metric Reporters监控作业

问题一:flink sql消费kafka有办法控制消费速度么? flink sql消费kafka有办法控制消费速度么? 参考答案: 目前没办法限制消费速度的 关于本问题的更多回答可点击进行查看: https://developer.aliyun.com/ask/639652 问题二:fli...

实时计算 Flink版产品使用问题之怎么使用Metric Reporters监控作业
文章 2024-08-19 来自:开发者社区

实时计算 Flink版产品使用问题之如何实现全局监控

问题一:Flink有遇到开启kerbores 认证的Hadoop集群吗? Flink有遇到开启kerbores 认证的Hadoop集群,flink(1.17.2)的stanalone模式启动报错,Failed to initialize delegation token provider {}.只要一引入Hadoop的包或者配置环境变量就报错? 参考答案: ...

实时计算 Flink版产品使用问题之如何实现全局监控
问答 2024-08-13 来自:开发者社区

玄武实时计算平台是如何监控每个作业的运行状态的?

玄武实时计算平台是如何监控每个作业的运行状态的?

问答 2024-08-12 来自:开发者社区

在Flink CDC中,我使用flinkcdc监控sqlserver,这是什么呀?

在Flink CDC中,我使用flinkcdc监控sqlserver,表里的这个字段值SELF_REFERENCE的是null值,但是flinkcdc读取出来的值是"SELF_REFERENCE": "'N",这张表的这个字段设置的是SELF_REFERENCE nvarchar(1)DEFAULT N'N' NULL,使用的cdc版本是com.ververicaflink-connector-....

问答 2024-07-29 来自:开发者社区

如何通过监控来定位和处理Flink作业中的反压问题?

如何通过监控来定位和处理Flink作业中的反压问题?

问答 2024-07-29 来自:开发者社区

Flink日常监控主要包括哪些内容?

Flink日常监控主要包括哪些内容?

问答 2024-07-24 来自:开发者社区

有实现flink全链路业务数据的延时监控的方案吗?

有实现flink全链路业务数据的延时监控的方案吗,目前看flip-384只监控了检查点情况

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

实时计算 Flink版操作报错合集之在设置监控PostgreSQL数据库时,将wal_level设置为logical,出现一些表更新和删除操作报错,怎么办

问题一:Flink CDC里,ticdc老报这个是为什么? Flink CDC里,ticdc老报这个是为什么?java.lang.NullPointerException: Failed to init client for PD cluster. 参考答案: 这个问题可能是由于在初始化PD(Placement Driver)集群客户端时出现了空指针异...

实时计算 Flink版操作报错合集之在设置监控PostgreSQL数据库时,将wal_level设置为logical,出现一些表更新和删除操作报错,怎么办

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

产品推荐

阿里云实时计算Flink

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

+关注