You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by rm...@apache.org on 2014/06/26 11:46:42 UTC
[17/53] [abbrv] git commit: Standardized creation of input and output
channels in InputGate and OutputGate. Removed linear contains check in
InputGate for channels.
Standardized creation of input and output channels in InputGate and OutputGate. Removed linear contains check in InputGate for channels.
Project: http://git-wip-us.apache.org/repos/asf/incubator-flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-flink/commit/26926433
Tree: http://git-wip-us.apache.org/repos/asf/incubator-flink/tree/26926433
Diff: http://git-wip-us.apache.org/repos/asf/incubator-flink/diff/26926433
Branch: refs/heads/travis_test
Commit: 26926433cbb82ee1789622b6f9baf0638907a69e
Parents: e52fcf9
Author: Till Rohrmann <ti...@gmail.com>
Authored: Wed Apr 9 19:35:57 2014 +0200
Committer: Stephan Ewen <se...@apache.org>
Committed: Sun Jun 22 21:07:20 2014 +0200
----------------------------------------------------------------------
.../eu/stratosphere/nephele/execution/RuntimeEnvironment.java | 6 ------
1 file changed, 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/26926433/stratosphere-runtime/src/main/java/eu/stratosphere/nephele/execution/RuntimeEnvironment.java
----------------------------------------------------------------------
diff --git a/stratosphere-runtime/src/main/java/eu/stratosphere/nephele/execution/RuntimeEnvironment.java b/stratosphere-runtime/src/main/java/eu/stratosphere/nephele/execution/RuntimeEnvironment.java
index 70718a9..2416b07 100644
--- a/stratosphere-runtime/src/main/java/eu/stratosphere/nephele/execution/RuntimeEnvironment.java
+++ b/stratosphere-runtime/src/main/java/eu/stratosphere/nephele/execution/RuntimeEnvironment.java
@@ -83,12 +83,6 @@ public class RuntimeEnvironment implements Environment, BufferProvider, LocalBuf
private final List<InputGate<? extends IOReadableWritable>> inputGates = new CopyOnWriteArrayList<InputGate<? extends IOReadableWritable>>();
/**
- * Queue of unbound output gate IDs which are required for deserializing an environment in the course of an RPC
- * call.
- */
- private final Queue<GateID> unboundOutputGateIDs = new ArrayDeque<GateID>();
-
- /**
* Queue of unbound input gate IDs which are required for deserializing an environment in the course of an RPC
* call.
*/