Jul 05 17:38:34 Caused by: java.lang.IllegalStateException: Result partition is already released.
Jul 05 17:38:34 at org.apache.flink.util.Preconditions.checkState(Preconditions.java:193)
Jul 05 17:38:34 at org.apache.flink.runtime.io.network.partition.hybrid.HsResultPartition.finish(HsResultPartition.java:264)
Jul 05 17:38:34 at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:778)
Jul 05 17:38:34 at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575)
Jul 05 17:38:34 at java.lang.Thread.run(Thread.java:750)