最新 最热

读Flink源码谈设计:有效管理内存之道

在最初接触到Flink时,是来自于业界里一些头部玩家的分享——大家会用其来处理海量数据。在这种场景下,如何避免JVM GC带来StopTheWorld带来的副作用这样的问题一直盘绕在我心头。直到用了Flink以后,阅读了相关的源码(以1....

2023-12-27
0

java 17运行jar报错:java.lang.UnsatisfiedLinkError: Can't load library:

The following packages were automatically installed and are no longer required:

2023-09-17
1

Flink Checkpoint/Savepoint对比

Flink 为作业的容错提供 Checkpoint 和 Savepoint 两种机制。保存点机制(Savepoints)是检查点机制一种特殊的实现,它允许你通过手工方式来触发Checkpoint,并将结果持久化存储到指定路径中,主要用于避免Flink集群在重启或升...

2023-09-17
1

Flink实时写入StarRocks NullPointerException问题解决

最近出现很多任务经常跑着跑着就failed了,也不怎么重启,翻了下异常信息如下,大概意思就是进行stream load的时候失败了,然后回滚了下,然后就空指针了...

2023-05-22
0