netty源码编译错误 Failure to find io.netty:netty-tcnative:jar:${os.detected.classifier}:2.0.7.Final in 2021-10-08 浏览(362) 评论(0) 阅读全文
Flink Flink广播流checkpoints失败 Checkpoint triggering task Source: Collection Source (1/1) of job xxxx is not in state RUNNING but FINISHED instead. Aborting checkpoint. 2021-03-08 浏览(913) 评论(0) 阅读全文
Spark Spark中任务报错java.io.IOException: Filesystem closed Filesystem closed由于Spark程序以Spark-On-Yarn模式运行,Spark会把job日志是写在HDFS上。他们使用的是同一个FileSystem,从而导致异常。 2021-02-03 浏览(697) 评论(0) 阅读全文
Flink org/apache/flink/api/common/functions/FlatMapFunction java.lang.NoClassDefFoundError:,org/apache/flink/api/common/functions/FlatMapFunction 2021-01-25 浏览(612) 评论(0) 阅读全文