Flink Sql开发中,Flink提供了哪些watermark策略? Flink Sql开发中,Flink提供了哪些watermark策略?... 帅平 /大数据 /2023-07-31 /1 评论 /158 阅读
Flink Sql开发系列(一)Flink Sql术语介绍 在本站我们介绍过很多flink相关的开发,对于flink sql而言,我们介绍的比较少,所以从本文开始,我们介绍下flink sql开发系列的相关知识点,在学习flink sql开发之前,我们要理解下flink sq... Rae /flink系列 /2023-07-31 /0 评论 /490 阅读
Dinky 实时计算平台系列(二十一)FlinkSql作业开发之FlinkSql-cdc + kafka 在前面两篇文章《Dinky 实时计算平台系列(十九)FlinkSql作业开发之FlinkSql-Kafka》和《Dinky 实时计算平台系列(二十)FlinkSql作业开发之FlinkSql-cdc》。本文的话,我们... Rae /flink系列 /2023-07-31 /0 评论 /633 阅读
Dinky 实时计算平台系列(二十)FlinkSql作业开发之FlinkSql-cdc 上一篇文章《Dinky 实时计算平台系列(十九)FlinkSql作业开发之FlinkSql-Kafka》我们介绍了flinksql中kafka的connector,在实际的业务中我们还会涉及到的有mysql的cdc,... Rae /flink系列 /2023-07-29 /0 评论 /546 阅读
Dinky 实时计算平台系列(十九)FlinkSql作业开发之FlinkSql-Kafka 上一篇文章《Dinky 实时计算平台系列(十八)FlinkSql作业开发之快速演示》我们在dinky中进行了一个简单的演示开发,从现在开始,我们切合实际情况,做一些flink多数据源的connector方面的开发,本... Rae /flink系列 /2023-07-29 /0 评论 /825 阅读
Flinksql中运行的时候报错,提示:NoSuchMethodError: org.apache.flink.table.types.logical.utils.LogicalTypeChecks. Flinksql中运行的时候报错,提示:Caused by: java.lang.NoSuchMethodError: org.apache.flink.table.types.logical.utils.Log... 帅平 /大数据 /2023-07-29 /1 评论 /270 阅读
Dinky 实时计算平台系列(十八)FlinkSql作业开发之快速演示 本文的话,我们使用官网的案例来演示下在Dinky平台上开发一个flinksql的作业。下面直接开始.1)首先创建一个作业这里我们创建一个名为test2的作业,此时就会在右侧打开一个新的黑框。如下图:2)在黑框里面编写... Rae /flink系列 /2023-07-29 /0 评论 /550 阅读
这个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,col... 帅平 /大数据 /2023-07-21 /1 评论 /187 阅读
Dinky中创建catalog报错:Table (or view) default_database.tbl_contract_detail already exists in Catalog 使用Dinky执行Flinksql的时候报错了,提示:table.catalog.exceptions.TableAlreadyExistException:Table (or view) default_dat... 帅平 /大数据 /2023-07-21 /1 评论 /244 阅读
Dinky 实时计算平台系列(十七)Dinky数据开发之FlinkSql作业保存点 在dinky的flinksql数据开发编辑器的右侧,还有一个比较重要的功能就是保存点,如下图:这个保存点不是用来配置的,它是一系列的记录。当我们在调试这个作业的时候,我们通过该cancel命令停止作业的时候,会自动生... Rae /flink系列 /2023-07-21 /0 评论 /583 阅读