实时数仓开发 - doris/pg/flink

窗口类型：滚动窗口@Override@Override@Override//乱序时间} else {// 10s内没有数据则关闭当前窗口state.f1){System.out.println("触发窗口,maxWatermark + 6000L:" + (maxWatermark + 6000L));} else {System.out.println("正常发送水印");代码部分逻辑说明。

doris-学习笔记

flink 任务处于 created 状态

akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka.tcp://flink@hostname:端口/user/rpc/taskmanager_0#-1963283773]] after [10000 ms]. Message of type [org.apache.flink.runtime.rpc.messages.Rem

flinkSlot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout解决：减少并发度

报错信息：ZooKeeper node /hiveserver2 is not ready yet现象：HIVE METASTORE 服务显示正常，启动 HIVESERVER2 报错原因：HIVE METASTORE 服务显示正常，但服务无法连接解决：重启 HIVE METASTORE ， 再重启 HIVESERVER2 即可...

doris-sql优化

flink sql - 新增pg批量写入参数导致的pg表死锁分析

hive 的string与bigint的比较