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

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

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

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

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

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

文章 2024-05-19 来自:开发者社区

实时计算 Flink版操作报错合集之报错显示“Unsupported SQL query! sqlUpdate() only accepts SQL statements of type INSERT and DELETE"是什么意思

问题一:开源flink都是可以通过这个来创建,但在blink上试用TableApi去这样写,就报错,为什么? 开源flink都是可以通过tableEvn.sqlUpdate("create table")来创建表的但是今天在blink上试了用TableApi去这样写,就报错,为什么?Unsupported SQL query! sqlUpdate() only accepts ...

实时计算 Flink版操作报错合集之报错显示“Unsupported SQL query! sqlUpdate() only accepts SQL statements of type INSERT and DELETE
问答 2023-09-20 来自:开发者社区

flink sql中间insert xx select xx 的算子可以设置并行度么?

flink sql除了source 和sink,中间insert xx select xx 的算子可以设置并行度么?embed 配置如下:

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

Flink CDC中cdc mysql sql语法有参数控制只捕获insert语句吗?

Flink CDC中cdc mysql sql语法有参数控制只捕获insert语句吗?

问答 2023-06-18 来自:开发者社区

请问,Flink CDC 中这个SQL咋这么怪,insert 后面怎么有 ON CONFLICT ?

请问,Flink CDC 中这个SQL咋这么怪,insert 后面怎么有 ON CONFLICT (ID) DO UPDATE SET ID=EXCLUDED.ID, city_code=EXCLUDED.city_code, city_name=EXCLUDED.city_name, province_code=EXCLUDED.province_code? postgresql 没有 这种语....

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

请问一个flink sql作业中写了2个Insert into语句,实际执行的时候只执行了第一个in

请问一个flink sql作业中写了2个Insert into语句,实际执行的时候只执行了第一个insert into,请问是什么原因呢?

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

flink cdc 采集多表,大家sql咋写的? 是多个insert 写到一起么?

flink cdc 采集多表,大家sql咋写的? 是多个insert 写到一起么?

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

flink sql从pg同步数据,在flink sql创建表,然后insert,重复操作几遍就报这个

flink sql从pg同步数据,在flink sql创建表,然后insert,重复操作几遍就报这个错,表都是有主键的,哪位大佬知道原因吗?

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

产品推荐

阿里云实时计算Flink

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

+关注
AI助理

你好,我是AI助理

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