我们在用flink sql 做实时指标计算时,insert into语句能否动态修改?
我们在做指标计算时,如果用户修改了指标计算的sql(目前暂定只修改insert into 中 select 的内容,如何不重启flink 任务实现,我的想法时通过定时任务,读取数据库中sql的配置信息,然后比较缓存的内容,如果有新的就 tabEnv.executeSql新的sql,请问这种方法是否可能,如果不行的话,有什么比较好的方法?
实时计算Flink SQL如何实现insert overwrite到Hologres结果表
实时计算Flink SQL如何实现insert overwrite到Hologres结果表
实时计算 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 sql中间insert xx select xx 的算子可以设置并行度么?
flink sql除了source 和sink,中间insert xx select xx 的算子可以设置并行度么?embed 配置如下:
请教个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)';
Flink CDC中cdc mysql sql语法有参数控制只捕获insert语句吗?
Flink CDC中cdc mysql sql语法有参数控制只捕获insert语句吗?
请问,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 没有 这种语....
请问一个flink sql作业中写了2个Insert into语句,实际执行的时候只执行了第一个in
请问一个flink sql作业中写了2个Insert into语句,实际执行的时候只执行了第一个insert into,请问是什么原因呢?
flink cdc 采集多表,大家sql咋写的? 是多个insert 写到一起么?
flink cdc 采集多表,大家sql咋写的? 是多个insert 写到一起么?
flink sql从pg同步数据,在flink sql创建表,然后insert,重复操作几遍就报这个
flink sql从pg同步数据,在flink sql创建表,然后insert,重复操作几遍就报这个错,表都是有主键的,哪位大佬知道原因吗?
本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。
实时计算 Flink版您可能感兴趣
- 实时计算 Flink版CDC
- 实时计算 Flink版batch
- 实时计算 Flink版优化
- 实时计算 Flink版DDL
- 实时计算 Flink版模式
- 实时计算 Flink版Iceberg
- 实时计算 Flink版好礼
- 实时计算 Flink版实践
- 实时计算 Flink版分析
- 实时计算 Flink版实战
- 实时计算 Flink版数据
- 实时计算 Flink版SQL
- 实时计算 Flink版mysql
- 实时计算 Flink版报错
- 实时计算 Flink版同步
- 实时计算 Flink版任务
- 实时计算 Flink版flink
- 实时计算 Flink版实时计算
- 实时计算 Flink版版本
- 实时计算 Flink版oracle
- 实时计算 Flink版kafka
- 实时计算 Flink版表
- 实时计算 Flink版配置
- 实时计算 Flink版产品
- 实时计算 Flink版Apache
- 实时计算 Flink版设置
- 实时计算 Flink版作业
- 实时计算 Flink版数据库
- 实时计算 Flink版运行
- 实时计算 Flink版连接