Flink 任务卡死，不消费。
1：业务运行一段时间后出现卡死。
2：实际下游算子并未出现死锁情况。
3：关闭ck后，运行3d未出现。
4：增加输入并发压力，出现概率更高，运行30min 左右可能就出现。
线程栈基本都是在wait 状态：
{
"threadName": "log-reduce (1/1)#8",
"stringifiedThreadInfo": "\"log-reduce (1/1)#8\" Id=111 WAITING on java.util.concurrent.CompletableFuture$Signaller@498e8c80\n\tat sun.misc.Unsafe.park(Native Method)\n\t- waiting on java.util.concurrent.CompletableFuture$Signaller@498e8c80\n\tat java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)\n\tat java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1707)\n\tat java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3323)\n\tat java.util.concurrent.CompletableFuture.waitingGet(CompletableFuture.java:1742)\n\tat java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)\n\tat org.apache.flink.runtime.io.network.buffer.LocalBufferPool.requestMemorySegmentBlocking(LocalBufferPool.java:346)\n\tat org.apache.flink.runtime.io.network.buffer.LocalBufferPool.requestBufferBuilderBlocking(LocalBufferPool.java:318)\n\t...\n\n"
},
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。