SQL
-
Flink sql中的GROUP_CONCAT 函数 得怎么实现?-[阿里云_云淘科技]
Flink sql中的GROUP_CONCAT 函数 得怎么实现? 以下为热心网友提供的参考意见 LISTAGG ,此回答整理自钉群“实时计算Flink产品交流群” 以下为热心网友…
-
一个Flink SQL Job 能同时订阅多个MySql表的Binlog吗?-[阿里云_云淘科技]
一个Flink SQL Job 能同时订阅多个MySql表的Binlog吗? 以下为热心网友提供的参考意见 可以的,但是会起多个binlog dump链接,因为mysql不支持按表…
-
大佬们,我刚接触flink,请教个问题,flinksql不支持这样写吗,数据库函数? -[阿里云_云淘科技]
大佬们,我刚接触flink,请教个问题,flinksql不支持这样写吗,数据库函数? 在数据库是可以执行的,但是在flink校验sql的 时候报错了? 以下为热心网友提供的参考意见…
-
请教一下怎么用flinksql 写一个连接带有kerberos 认证的 hive 的catalog?-[阿里云_云淘科技]
请教一下怎么用flinksql 写一个连接带有kerberos 认证的 hive 的catalog? 以下为热心网友提供的参考意见 flink必须写到配置文件里,kerberos配…
-
有没部署过flink sql gateway的呀?一直报错?-[阿里云_云淘科技]
有没部署过flink sql gateway的呀?一直报错 org.apache.thrift.protocol.TProtocolException: Missing versi…
-
如果使用flink sql的left join,右表出现部分关联不上的情况,应该怎么处理好?-[阿里云_云淘科技]
请问下,如果使用flink sql的left join,右表出现部分关联不上的情况,应该怎么处理好一点哈? 以下为热心网友提供的参考意见 在使用Flink SQL的LEFT JOI…
-
请教个问题,flink使用sql插入数据,插入过程中有异常数据,通过sql的方式可以处理吗?-[阿里云_云淘科技]
请教个问题,flink使用sql插入数据,插入过程中有异常数据,通过sql的方式可以处理吗? 以下为热心网友提供的参考意见 是的,Flink SQL提供了一些内置函数和操作符来处理…
-
Flink binlog 收到这样一条sql 任务就崩溃了,怎么解决呀?-[阿里云_云淘科技]
Flink binlog 收到这样一条sql 任务就崩溃了,怎么解决呀?已经稳定运行很久了 最近出现了这样一个错 以下为热心网友提供的参考意见 楼主你好,你的错误信息表明阿里云Fl…
-
flink 1.18启动sql client异常 ,有人知道为什么吗?-[阿里云_云淘科技]
flink 1.18启动sql client异常 ,有人知道为什么吗? 以下为热心网友提供的参考意见 我是加个sudo就好了 或者环境变量没配置好 或者多个版本环境变量配置冲突 ,…
-
ADB MySQL湖仓版这个怎么用,有示例的SQL吗?-[阿里云_云淘科技]
ADB MySQL湖仓版这个怎么用,有示例的SQL吗? 以下为热心网友提供的参考意见 ADB MySQL湖仓版是一个基于阿里云数据库的大数据存储和处理解决方案,它提供了高性能、高可…
-
想问下Flink sql作业支持写判断语句吗,根据标志执行删除,或是更新或是插入?-[阿里云_云淘科技]
想问下Flink sql作业支持写判断语句吗,根据标志执行删除,或是更新或是插入? 以下为热心网友提供的参考意见 是的,Flink SQL支持写判断语句。您可以使用CASE WHE…
-
请问一下,flink sql udf 通过字符串这样传进来,大家有没有一个好的实现办法呀?-[阿里云_云淘科技]
请问一下,flink sql udf 通过字符串这样传进来,然后用groovy编译成Class,然后通过tableEnv去注册,这样会报错。大家有没有一个好的实现办法呀?外面传个字…