[FLINK-980] Fix buffer leak in OutputChannel

f13ad5b4 · uce · 2f0bd8fa · f13ad5b4
显示空白变更内容
内联并排

Showing with 1 addition and 0 deletion

stratosphere-runtime/src/main/java/eu/stratosphere/runtime/io/channels/OutputChannel.java ...va/eu/stratosphere/runtime/io/channels/OutputChannel.java +1 -0

未找到文件。
--- a/stratosphere-runtime/src/main/java/eu/stratosphere/runtime/io/channels/OutputChannel.java
+++ b/stratosphere-runtime/src/main/java/eu/stratosphere/runtime/io/channels/OutputChannel.java
@@ -66,6 +66,7 @@ public class OutputChannel extends Channel {

 		// discard empty buffers
 		if (buffer.size() == 0) {
+			buffer.recycleBuffer();
 			return;
 		}