问答 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-06-10 来自:开发者社区

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

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

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

我该在Flink什么位置设置才能是insert into select 一直运行下去直到手动停止?

我的insert into select 作业自动变成已完成状态,我想让他一直保持运行状态,是需要添加 execution.checkpointing.interval=10这个参数哇。但是上次此时发现这个参数在sql中是不生效的,我该在Flink什么位置设置才能是insert into select 一直运行下去直到手动停止?

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

Flink如果改成一个job里面只有一个insert into的语句执行?

"Flink如果改成一个job里面只有一个insert into的语句执行,是可以顺利恢复的,有多个语句就不能恢复了,但是恢复时只执行第一个语句是没有问题的。现在我是一个job里面多个insert 任务嘛,请问我要插入多个宽表的话,如何在一个job里面的一个任务里面完成?"

文章 2024-02-24 来自:开发者社区

Flink报错问题之Flink报错Only a single 'INSERT INTO' is supported如何解决

问题一:实时计算Flink报错Only a single 'INSERT INTO' is supported 实时计算Flink报错Only a single 'INSERT INTO' is supported 参考答案: 可参考QA:报错:Only a single 'INSERT INTO' is supported ...

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

Flink CDC怎么将结果insert into到mysql里一张带有自增ID的表里?

Flink CDC怎么将结果insert into到mysql里一张带有自增ID的表里?

问答 2023-08-28 来自:开发者社区

请教个flink sql 的时间比较问题 insert into A select * ?

请教个flink sql 的时间比较问题 insert into A select from B where timstamp >= '2023-01-01'; 这样的flinksql 咋写?insert into A select from B where timstamp >= to_TimeStamp('2023-01-01 00:00:00)';

问答 2023-08-28 来自:开发者社区

flink cdc 增量阶段是通过什么插入的 insert into 还是insert?

flink cdc 增量阶段是通过什么插入的insert into 还是insert upsert 啥的,有大佬知道吗?

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

产品推荐

实时计算 Flink

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

+关注
AI助理

你好,我是AI助理

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