阿里云文档 2025-11-27

使用ModifyPrepayInstanceSpec API修改包年包月实例的计算资源规格-实时计算 Flink版-阿里云

修改包年包月的flink全托管实例计算资源的规格大小,调整后规格小于当前使用规格将进行缩容操作,调整后规格大于当前使用规格将进行扩容操作。

问答 2024-09-26 来自:开发者社区

我们在用flink sql 做实时指标计算时,insert into语句能否动态修改?

我们在做指标计算时,如果用户修改了指标计算的sql(目前暂定只修改insert into 中 select 的内容,如何不重启flink 任务实现,我的想法时通过定时任务,读取数据库中sql的配置信息,然后比较缓存的内容,如果有新的就 tabEnv.executeSql新的sql,请问这种方法是否可能,如果不行的话,有什么比较好的方法?

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

flink sql作业中,计算结果可以动态写入kafka不同主题吗?

flink sql作业中,计算结果可以动态写入kafka不同主题吗?

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

flink 1.13版本 sql中如果一直没有数据到来,则窗口不触发计算sql中怎么设置空闲时间呢?

请教下,flink 1.13版本 sql中,对于event时间语义,如果一直没有数据到来,则窗口不触发计算,sql中怎么设置空闲时间呢?

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

Flink SQL如何计算数据从读取到输出的时间差

Flink SQL如何计算数据从读取到输出的时间差

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

Flink SQL计算任务从checkpoint恢复流程是怎样的

Flink SQL计算任务从checkpoint恢复流程是怎样的

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

请问flink sql 事件时间 Temporal Join 设计多个并行度不触发计算

环境说明:flink 1.15 场景描述:left 表是一个来源于kafka的表且定义了水位线,right表是来自于mysql cdc的表,right表定义了主键和水位线,按flink官方说法right表就是一个版本表了。2个表按FOR SYSTEM_TIME AS OF事件时间的方式关联。且关联字段都是主键。在执行环境中设置了程序的并行度为3。 问题描述:right表本身有不少数据了,当lef....

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

请问flink sql 事件时间 Temporal Join 不触发计算

环境说明:flink 1.15 场景描述:left 表是一个来源于kafka的表且定义了水位线,right表是来自于mysql cdc的表,right表定义了主键和水位线,按flink官方说法right表就是一个版本表了。2个表按FOR SYSTEM_TIME AS OF事件时间的方式关联。且关联字段都是主键。 问题描述:right表本身有不少数据了,当left来一条数据的时候结果没有触发计算。....

阿里云文档 2023-12-20

将物联网平台数据集成到阿里云实时计算Flink版中计算和分析_物联网平台(IoT)

物联网平台数据服务中的产品属性时序表、产品事件表和自定义存储表(时序表)数据,可以集成到阿里云实时计算Flink版中计算和分析,以便您实时分析和诊断设备的运行状况,实时检测运行故障等。本文介绍使用实时计算Flink版的连接器功能集成物联网平台实例下数据服务中数据的完成流程。

问答 2023-12-03 来自:开发者社区

flink sql写累积窗口 开一天 每5分钟输出一次数据,为啥最后没有触发计算啊?

flink sql写累积窗口 开一天 每5分钟输出一次数据,为啥最后没有触发计算啊?

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

实时计算 Flink版更多计算相关

产品推荐

阿里云实时计算Flink

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

+关注