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

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

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

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

现在flink支持with insert into语句吗?

现在flink支持with insert into语句吗?

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

在Flink CDC中,insert into 任务提交到flink上去了?

在Flink CDC中,insert into 任务提交到flink上去了,看日志也没报错。消费者也能消费到数据。 hive表数据没同步过来(不是分区表)。 不知道哪里出了问题?

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

Flink的insert方式 是要提前建表 而且不会同步表结构变更的么?

Flink的insert方式 是要提前建表 而且不会同步表结构变更的么?

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

实时计算 Flink版产品使用问题之如何在TableEnvironment中执行一条INSERT语句,或者通过StatementSet执行多条INSERT语句

问题一:Flink中executeplain和statementset怎么结合? Flink中executeplain和statementset怎么结合? 参考答案: 主要用于批处理 SQL 程序中...

实时计算 Flink版产品使用问题之如何在TableEnvironment中执行一条INSERT语句,或者通过StatementSet执行多条INSERT语句
问答 2024-07-03 来自:开发者社区

对于Flink CDC,可以通过两个source一个监听insert 一个监听update 可以嘛?

对于Flink CDC,可以通过两个source一个监听insert 一个监听update 这样可以吗?

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

对于Flink CDC,把insert和update 拆分开处理,有什么好的方法处理吗?

对于Flink CDC,现在flink程序监听一个表的insert和update事件,但是由于update的变更量过大导致insert有延迟的情况,我现在想要把insert和update 拆分开处理,有什么好的方法处理吗?

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

实时计算Flink SQL如何实现insert overwrite到Hologres结果表

实时计算Flink SQL如何实现insert overwrite到Hologres结果表

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

问一下Flink,查询insert into的表,没有数据,知道是怎么回事么?

问一下Flink,我这边数据源是paimon,查询是有数据的,执行 insert into select,查询insert into的表,没有数据,有大佬知道是怎么回事么?

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

实时计算Flink提示Only INSERT and DELETE record are su...

实时计算Flink提示Only INSERT and DELETE record are supported if keys are not defined

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

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注