flink遇到的坑

flink运行一切顺利,在发送数据量快达到1G的时候,忽然发生故障,无端重启,最终致使整个flink程序崩溃。html 发现问题后,就开始测试,追踪到日志,以下:java AsynchronousException{java.lang.Exception: Could not materialize checkpoint 1143 for operator logData -> Sink: hos
相关文章
相关标签/搜索