Flink的问题分析与解决
发布时间
阅读量：
阅读量
1.local运行报错
Flink任务执行器关闭异常
现象：在运行过程中，初期流处理任务均能正常执行，但数秒后便出现停滞现象。通过调试与日志分析发现，Mini Cluster在此时被终止。然而，使用相同代码及依赖项的其他同学却能够顺利运行，因此判断为环境配置问题，但具体原因尚不明确。
原因：问题源于JDK版本差异，即便是JDK 1.8的不同小版本之间也存在兼容性问题。本人使用的版本为1.8.0_25，而切换至1.8.0_162后问题得以解决！！
未导入日志包时出现错误：
[Source: Custom Source -> Map -> Timestamps/Watermarks -> Map (1/1)] ERROR org.apache.flink.runtime.taskmanager.Task - FATAL - exception in resource cleanup of task Source: Custom Source -> Map -> Timestamps/Watermarks -> Map (1/1) (5794d243fa9118faec953fa5ef3499c2).
java.lang.IllegalStateException: Memory manager has been shut dow全部评论 (0)
还没有任何评论哟~