阿里云文档 2024-09-03

INSERT INTO语句

本文为您介绍如何使用INSERT INTO语句在一个作业中写入一个Sink或多个Sink。

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

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

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

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

flink 任务insert into TWORKSHEET_hudi select * from

flink 任务insert into TWORKSHEET_hudi select * from TWORKSHEET where TCTIME BETWEEN '2017-06-1 23:59:59' AND '2019-09-25 23:59:59'; index_bootstrap阶段报错org.apache.hudi.exception.HoodieIOException: Cou...

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

使用flink sql,insert into mysql表 select from hive表,h

使用flink sql,insert into mysql表 select from hive表,hive表中有个字段有表情符,无法写入mysql,mysql已设置为utf8mb4编码,使用mysql客户端是可以写进去的,哪位解决过或知道原因的吗?

问答 2022-06-21 来自:开发者社区

flink SQL batch hive 写hive ,insert 后面select 是有数据

flink SQL batch hive 写hive ,insert 后面select 是有数据的 就不会报错,可以正常写入,如果没有就会报 .staging_1655779371066 does not exist.请问知道原因嘛?

问答 2021-12-07 来自:开发者社区

flink sql 1.10 insert into tb select 复杂schema 失败

create table xxx ( a string, b row( c row(d string) ) ) 当c 中有值的时候,sql 如下 insert into select * from xxx会出现下面错误 Caused by: java.lang.ClassCastException: org.apache.flink.shaded.jackson2.com.fasterxml...

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

产品推荐

阿里云实时计算Flink

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

+关注
AI助理

你好,我是AI助理

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

登录插画

登录以查看您的控制台资源

管理云资源
状态一览
快捷访问