请问一下paimon的流批一体, 指的是存储和读写的一体吗? 请问一下paimon的流批一体, 指的是存储和读写的一体吗? 计算代码是否也是一套能搞定呢? 比如flink sql流读写法和spark sql写法不一样,比较好奇这一点。... 帅平大数据2025-06-10606 阅读1 评论
Flink sql基于事件时间的窗口函数 没有新数据 最后一个窗口不触发怎么办? Flink sql基于事件时间的窗口函数 没有新数据 最后一个窗口不触发怎么办?... Rae大数据2025-05-08529 阅读1 评论
使用dinky执行flink sql从kafka同步数据一般需要设置哪些环境变量? 使用dinky执行flink sql从kafka同步数据一般需要设置哪些环境变量?... 帅平大数据2025-03-24606 阅读1 评论
问一下大家,启动flink sql-gateway如何指定通过yarn session来启动? 问一下大家,启动flink sql-gateway如何指定通过yarn session来启动?... 帅平大数据2025-03-11724 阅读3 评论
kafka 中字段为空字符串""时,导致flink sql 写 doris 字段错位如何解决? kafka 中字段为空字符串""时,导致flink sql 写 doris 字段错位如何解决?... 帅平大数据2024-12-30638 阅读1 评论
Flink sql中如何在streaming模式和batch模式下切换? Flink sql中如何在streaming模式和batch模式下切换?... 帅平大数据2024-12-24688 阅读2 评论
热文Dinky 实时计算平台系列(二十二)FlinkSql作业开发之FlinkSql-cdc + doris 在日常的业务场景中,我们使用flink做cdc的工作的时候,大多数都有这样的需求,把mysql的数据近视的导入到doris中做分析。为了方便简写代码,这里我们使用Dinky来演示下把mysql的数据使用cdc同步到d... Raeflink系列2023-09-052747 阅读0 评论
热文Flink Sql开发系列(九)Flink Sql中内置函数 在flink sql的开发中,我们还会涉及到很多的sql内置函数,可以让我们在sql开发中很方便的对数据进行处理。本文的话我们列举下Flink Sql中内置的函数,截止的Flink 版本为1.17。1)value1 ... Raeflink系列2023-08-011865 阅读0 评论
热文Flink Sql开发系列(八)Flink Sql开发常用的建表语句模板 在flink sql开发中,我们必然会涉及到创建表的步骤,所以本文的话,我们介绍一些常用的建表语句模板。1)flink sql 创建kafka的表这里就是相当于with后面跟kafka,可以从kafka里面读取数据,... Raeflink系列2023-08-011511 阅读0 评论