C# 组合CancellationTokenSource的使用
异步超时机制,手动取消任务
Flink|checkpoint 超时报错问题处理(FlinkRuntimeException)
Flink 的 checkpoint 的超时时间时 600 秒,但是这个任务需要 11 分钟才能完成。另一方面也可能是因为线上运行时,对 MySQL 请求时走的是内网请求,而本地运行走的是外网请求。为了评估一个 Flink 程序的处理效果,我使用本地模式启动了 Flink 程序,并在上游表中一次性插
修改 RabbitMQ 默认超时时间
RabbitMQ默认的超时时间是30分钟,30分钟内一直无消息消费的话,则RabbitMQ会将Channel销毁,无法继续消费,导致代码报错。代码没动过,网络也ok,也设置了心跳和重连机制。PS,看到有篇文章也详细讲解了BUG的原因以及解决方法,又重复造轮子了.......方案二:修改业务,定时发送