1 用flink写的,能拿到flink结束但是flink结束之后easyexcel数据没写完 代码: public void processElement(Tuple2<Integer, List<Tuple3<Integer, List<List>, Integer>>> value, ProcessFunction<Tuple2<Integer, List<Tuple3<Integer, List<List>, Integer>>>, Object>.Context ctx, Collector out) throws Exception { Integer patientCount = value.f0; List<Tuple3<Integer, List<List>, Integer>> f1 = value.f1; AtomicInteger i = new AtomicInteger(); f1.forEach(of->{ Integer sheet = of.f0; List<List> lists = of.f1; synchronized (map) { excelWriter.write(lists, map.get(sheet)); i.getAndIncrement(); } }); getRuntimeContext().getAccumulator(taskId + "-handle").add(patientCount.longValue()); 业务上来说这边已经调用了write()方法,但是easyexcel没写完数据,拿不到什么时候write完成状态 ignore edit need translate Edit jiazhimin-hub