热文Flink Sql开发系列(四)Flink Sql开发之create相关的语句 在flink sql开发里面,我们知道运行的都是flink sql任务,所以所有的sql都是基于库表来执行的,因此这里的会涉及到创建的步骤。在flink sql中支持的创建场景有:1、创建catalog 2、创建da... Raeflink系列2023-07-311183 阅读0 评论
热文Flink Sql开发系列(三)Flink Sql中Set环境的配置 在flink sql开发中,我们有时候需要动态的调整配置参数,例如前面我们演示的:这里的set我们把它理解成设置的环境变量相关的配置。下面我们以flink1.17版本为例,列举下对应的set的环境变量的所有值:1)t... Raeflink系列2023-07-312694 阅读0 评论
热文Flink Sql开发系列(二)Flink Sql支持的数据类型 上一篇文章《Flink Sql开发系列(一)Flink Sql术语介绍》我们介绍了Flink sql开发中的一些术语,本文的话,既然是flink sql开发,那么我们介绍下flink sql开发中,Flink sql... Raeflink系列2023-07-311523 阅读0 评论
热文Flink Sql开发系列(一)Flink Sql术语介绍 在本站我们介绍过很多flink相关的开发,对于flink sql而言,我们介绍的比较少,所以从本文开始,我们介绍下flink sql开发系列的相关知识点,在学习flink sql开发之前,我们要理解下flink sq... Raeflink系列2023-07-311155 阅读0 评论
热文Dinky 实时计算平台系列(二十一)FlinkSql作业开发之FlinkSql-cdc + kafka 在前面两篇文章《Dinky 实时计算平台系列(十九)FlinkSql作业开发之FlinkSql-Kafka》和《Dinky 实时计算平台系列(二十)FlinkSql作业开发之FlinkSql-cdc》。本文的话,我们... Raeflink系列2023-07-311922 阅读0 评论
热文Dinky 实时计算平台系列(二十)FlinkSql作业开发之FlinkSql-cdc 上一篇文章《Dinky 实时计算平台系列(十九)FlinkSql作业开发之FlinkSql-Kafka》我们介绍了flinksql中kafka的connector,在实际的业务中我们还会涉及到的有mysql的cdc,... Raeflink系列2023-07-291627 阅读0 评论
热文Dinky 实时计算平台系列(十九)FlinkSql作业开发之FlinkSql-Kafka 上一篇文章《Dinky 实时计算平台系列(十八)FlinkSql作业开发之快速演示》我们在dinky中进行了一个简单的演示开发,从现在开始,我们切合实际情况,做一些flink多数据源的connector方面的开发,本... Raeflink系列2023-07-292144 阅读0 评论
热文Flinksql中运行的时候报错,提示:NoSuchMethodError: org.apache.flink.table.types.logical.utils.LogicalTypeChecks. Flinksql中运行的时候报错,提示: Caused by: java.lang.NoSuchMethodError: org.apache.flink.table.types.logical.utils.Logi... 帅平大数据2023-07-291131 阅读1 评论
热文Dinky 实时计算平台系列(十八)FlinkSql作业开发之快速演示 本文的话,我们使用官网的案例来演示下在Dinky平台上开发一个flinksql的作业。下面直接开始.1)首先创建一个作业这里我们创建一个名为test2的作业,此时就会在右侧打开一个新的黑框。如下图:2)在黑框里面编写... Raeflink系列2023-07-291534 阅读0 评论
flink写入doris ,只能跑一次, 重复执行就报lable已存在 ,这个则呢么解决昂? flink写入doris ,只能跑一次, 重复执行就报lable已存在 ,这个则呢么解决昂? 可以让他自己生成吗?... 帅平大数据2023-07-29841 阅读1 评论
热文请问一下各位大佬 Flink cdc 同步 mysql 中没有主键的 表时,怎么配置? 请问一下各位大佬 Flink cdc 同步 mysql 中没有主键的 表时,怎么配置?... 帅平大数据2023-07-261067 阅读1 评论
这个sql报错:SQL parse failed. Encountered "," at line 52,column 1. flink中sql报错: org.apache.flink.table.api.SqlParserException:SQL parse failed. Encountered "," at line 52,colu... 帅平大数据2023-07-21742 阅读1 评论
Dinky中创建catalog报错:Table (or view) default_database.tbl_contract_detail already exists in Catalog 使用Dinky执行Flinksql的时候报错了,提示: table.catalog.exceptions.TableAlreadyExistException:Table (or view) default_data... 帅平大数据2023-07-21958 阅读1 评论