I see tons of org.apache.flink.runtime.executiongraph.ExecutionGraph - Cannot update accumulators for job 7bfe57bb0ed1c5c2f4f40c2fccaab50d.
java.lang.NullPointerException https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java#L1715 Not sure why it is tagged ERROR and the pipe does not abort or what this implies.....