热文Flink写入数据到doris,没有报错,但是没有数据怎么排查? 读取flink读取doris表数据处理后在写入另一个doris表,任务过程没有报错,但是结果没有实现数据写入到doris表。这个是什么问题。... 帅平大数据2023-11-061328 阅读2 评论
flink kubernetes operator的jarURI的路径可以是hdfs么? 请问下 ,如果用 flink kubernetes operator 在kind: FlinkDeployment的情况下, jarURI的路径可以是hdfs么?... 帅平大数据2023-10-10988 阅读1 评论
热文如何在Dinky中集成dolphinscheduler和flink? 如何在Dinky中集成dolphinscheduler和flink?... 帅平大数据2023-09-241084 阅读1 评论
flink mysql client同步整个库--including-tables这个包括的表参数还需要吗? flink mysql client同步整个库--including-tables这个包括的表参数还需要吗?... 帅平大数据2023-09-14725 阅读1 评论
热文Flink创建paimon的catalog,使用S3协议的aws文件系统或者minio,怎么弄? Flink创建paimon的catalog,使用S3协议的aws文件系统或者minio,怎么弄?... 帅平大数据2023-09-061418 阅读1 评论
Flink创建paimon的catalog,使用阿里云的OSS文件系统,怎么弄? Flink创建paimon的catalog,使用阿里云的OSS文件系统,怎么弄?... 帅平大数据2023-09-06968 阅读1 评论
热文Flink table sql执行hive相关的语句的时候报错了,提示:ClassNotFoundException: com.facebook.fb303.FacebookService Flink table sql执行hive相关的语句的时候报错了,提示: [ERROR] Could not execute SQL statement. Reason: java.lang.ClassNotFoun... 帅平大数据2023-09-061071 阅读1 评论
热文Dinky 实时计算平台系列(二十二)FlinkSql作业开发之FlinkSql-cdc + doris 在日常的业务场景中,我们使用flink做cdc的工作的时候,大多数都有这样的需求,把mysql的数据近视的导入到doris中做分析。为了方便简写代码,这里我们使用Dinky来演示下把mysql的数据使用cdc同步到d... Raeflink系列2023-09-052738 阅读0 评论
热文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 unexpected... 帅平大数据2023-09-051110 阅读1 评论
热文Flink sql报错:Unknown identifier 'DATETIME' Flink sql执行的时候报错了,提示: Caused by: org.apache.calcite.sql.validate.SqlValidatorException: Unknown identifier '... 帅平大数据2023-09-051448 阅读1 评论
热文Flink应用开发系列(六十七)Table SQL开发之delete函数 在flink table sql中我们操作的是table表的数据,所以在日常的场景中也会涉及到delete删除数据语句,这里比较简单,和传统的mysql是一样的,示例语句如下:DELETE FROM Orders W... Raeflink系列2023-08-241736 阅读0 评论
热文Flink应用开发系列(六十六)Table SQL开发之update函数 在flink table sql中我们操作的是table表的数据,所以在日常的场景中也会涉及到update更新语句,这里比较简单,和传统的mysql是一样的,示例语句如下:UPDATE Orders SET `amo... Raeflink系列2023-08-241288 阅读0 评论
flink sql加载依赖包的时候报错:ClassNotFoundException: org.apache.htrace.core.Tracer$Builder flink sql加载hdfs上的依赖包的时候报错,信息如下: java.lang.ClassNotFoundException: org.apache.htrace.core.Tracer$Builder... 帅平大数据2023-08-24938 阅读1 评论