问答 2024-06-04 来自:开发者社区

Flink自动调优显示Update flink configuration of the jo...

Flink自动调优显示Update flink configuration of the job: table.exec.mini-batch.enabled: 'true' , table.exec.mini-batch.allow-latency: '5s'

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

Flink CDC里stop job超时怎么处理?

Flink CDC里stop job超时怎么处理?

问答 2024-03-06 来自:开发者社区

Flink双流JO IN 的TTL 怎么更改?具体怎么使用?

Flink双流JO IN 的TTL 怎么更改?具体怎么使用?

问答 2023-04-26 来自:开发者社区

prometheus能不能监控到flink job挂掉,带上flink job的名称,表名是哪个jo

prometheus能不能监控到flink job挂掉,带上flink job的名称,表名是哪个job挂,其它的指标都带有job name,但是flink job退出就没?还有什么配置?

问答 2022-12-04 来自:开发者社区

请教Flink CDC 个flink-sql的问题,flink 1.13.3 我这里有个不等的jo

请教Flink CDC 个flink-sql的问题,flink 1.13.3 我这里有个不等的join任务, 得到的这个节点的并行度无论怎么设置都是1,出现了性能瓶颈, 有没有什么方法能够触发广播或者别的方式把这里的负载均匀开

问答 2022-10-24 来自:开发者社区

当我使用flink cdc+ iceberg+hive同步数据,启用upsert时,提交sql jo

当我使用flink cdc+ iceberg+hive同步数据,启用upsert时,提交sql job报以下错误提示Equality field columns shouldn't be empty 已经设置了主键,使用了iceberg 的v2,请问是要在哪里设置一下吗

问答 2020-04-20 来自:开发者社区

请教一下,rocksdb checkpoint size不断增加有几种原因?跑了一个flink jo

请教一下,rocksdb checkpoint size不断增加有几种原因?跑了一个flink job,发现这一周checkpoint size在不断增加

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

产品推荐

阿里云实时计算Flink

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

+关注
X
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等