flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rmetz...@apache.org
Subject [34/34] git commit: Merge cleanups
Date Tue, 10 Jun 2014 19:35:31 GMT
Merge cleanups


Project: http://git-wip-us.apache.org/repos/asf/incubator-flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-flink/commit/99b4c62c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-flink/tree/99b4c62c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-flink/diff/99b4c62c

Branch: refs/heads/release-0.5.1
Commit: 99b4c62cb4dd5b0e3fe27ff5b1d98d0c3153850a
Parents: ffb5724
Author: StephanEwen <stephan.ewen@tu-berlin.de>
Authored: Thu Jun 5 15:45:49 2014 +0200
Committer: Robert Metzger <rmetzger@apache.org>
Committed: Tue Jun 10 21:27:25 2014 +0200

----------------------------------------------------------------------
 stratosphere-core/src/main/java/eu/stratosphere/types/Record.java  | 2 +-
 .../java/eu/stratosphere/nephele/execution/RuntimeEnvironment.java | 1 -
 2 files changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/99b4c62c/stratosphere-core/src/main/java/eu/stratosphere/types/Record.java
----------------------------------------------------------------------
diff --git a/stratosphere-core/src/main/java/eu/stratosphere/types/Record.java b/stratosphere-core/src/main/java/eu/stratosphere/types/Record.java
index 5b06547..73671fa 100644
--- a/stratosphere-core/src/main/java/eu/stratosphere/types/Record.java
+++ b/stratosphere-core/src/main/java/eu/stratosphere/types/Record.java
@@ -70,7 +70,7 @@ public final class Record implements Value, CopyableValue<Record>
{
 	
 	private Value[] writeFields;		// the cache for objects into which the binary representations
are read
 	
-	public int binaryLen;				// the length of the contents in the binary buffer that is valid
+	private int binaryLen;				// the length of the contents in the binary buffer that is valid
 	
 	private int numFields;				// the number of fields in the record
 	

http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/99b4c62c/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 29d6853..cc542c0 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
@@ -201,7 +201,6 @@ public class RuntimeEnvironment implements Environment, BufferProvider,
LocalBuf
 	 * @param inputSplitProvider the input split provider for this environment
 	 * @throws Exception thrown if an error occurs while instantiating the invokable class
 	 */
-	@SuppressWarnings({"unchecked", "rawtypes"})
 	public RuntimeEnvironment(final TaskDeploymentDescriptor tdd,
 							final MemoryManager memoryManager, final IOManager ioManager,
 							final InputSplitProvider inputSplitProvider,


Mime
View raw message