[FLINK-1193][java-api][scala-api] Fix copy method for ObjectArraySeri…

…alizer
Silven1117 · Feb 3, 2015 · 9906cba · 9906cba
1 parent 57b3e9f
commit 9906cba
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...core/src/main/java/org/apache/flink/api/common/typeutils/base/GenericArraySerializer.java b/...core/src/main/java/org/apache/flink/api/common/typeutils/base/GenericArraySerializer.java
@@ -72,8 +72,9 @@ public C[] copy(C[] from) {
 		C[] copy = create(from.length);
 
 		for (int i = 0; i < copy.length; i++) {
-			if (from[i] != null) {
-				copy[i] = this.componentSerializer.copy(from[i], this.componentSerializer.createInstance());
+			C val = from[i];
+			if (val != null) {
+				copy[i] = this.componentSerializer.copy(val);
 			}
 		}