flink mysql client同步整个库--including-tables这个包括的表参数还需要吗? flink mysql client同步整个库--including-tables这个包括的表参数还需要吗?... 帅平 /大数据 /2023-09-14 /1 评论 /204 阅读
Flink创建paimon的catalog,使用S3协议的aws文件系统或者minio,怎么弄? Flink创建paimon的catalog,使用S3协议的aws文件系统或者minio,怎么弄?... 帅平 /大数据 /2023-09-06 /1 评论 /324 阅读
Flink创建paimon的catalog,使用阿里云的OSS文件系统,怎么弄? Flink创建paimon的catalog,使用阿里云的OSS文件系统,怎么弄?... 帅平 /大数据 /2023-09-06 /1 评论 /226 阅读
Flink创建paimon的catalog,使用hdfs怎么弄? Flink创建paimon的catalog,使用hdfs怎么弄?... 帅平 /大数据 /2023-09-06 /1 评论 /167 阅读
Flink table sql执行hive相关的语句的时候报错了,提示:ClassNotFoundException: com.facebook.fb303.FacebookService Flink table sql执行hive相关的语句的时候报错了,提示:[ERROR] Could not execute SQL statement. Reason:java.lang.ClassNotFo... 帅平 /大数据 /2023-09-06 /1 评论 /233 阅读
热文Dinky 实时计算平台系列(二十二)FlinkSql作业开发之FlinkSql-cdc + doris 在日常的业务场景中,我们使用flink做cdc的工作的时候,大多数都有这样的需求,把mysql的数据近视的导入到doris中做分析。为了方便简写代码,这里我们使用Dinky来演示下把mysql的数据使用cdc同步到d... Rae /flink系列 /2023-09-05 /0 评论 /1001 阅读
Flink sql报错:Unable to convert to TimestampData from unexpected value '1637681884000' of type java.la Flink sql执行的时候报错了,提示:java.lang.IllegalArgumentException: Unable to convert to TimestampData from unexpecte... 帅平 /大数据 /2023-09-05 /1 评论 /221 阅读
Flink sql报错:Unknown identifier 'DATETIME' Flink sql执行的时候报错了,提示:Caused by: org.apache.calcite.sql.validate.SqlValidatorException: Unknown identifie... 帅平 /大数据 /2023-09-05 /1 评论 /241 阅读
Flink应用开发系列(六十七)Table SQL开发之delete函数 在flink table sql中我们操作的是table表的数据,所以在日常的场景中也会涉及到delete删除数据语句,这里比较简单,和传统的mysql是一样的,示例语句如下:DELETE FROM&nbs... Rae /flink系列 /2023-08-24 /0 评论 /676 阅读
Flink应用开发系列(六十六)Table SQL开发之update函数 在flink table sql中我们操作的是table表的数据,所以在日常的场景中也会涉及到update更新语句,这里比较简单,和传统的mysql是一样的,示例语句如下:UPDATE Orders&nbs... Rae /flink系列 /2023-08-24 /0 评论 /490 阅读