Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/4559
good catch, I completely missed the code path in `SpillableSubpartition` -
I agree with putting it under `synchronized(buffers)`---
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/4559
good catch, I completely missed the code path in `SpillableSubpartition` -
I agree with putting it under `synchronized(buffers)`---