flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From trohrm...@apache.org
Subject [5/9] flink git commit: [FLINK-3433] AvroOutputFormat#readObject uses readFully()
Date Tue, 23 Feb 2016 14:21:48 GMT
[FLINK-3433] AvroOutputFormat#readObject uses readFully()

This closes #1666


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

Branch: refs/heads/master
Commit: 77c1deedd859fed99970e27a6885856275ae23a9
Parents: 8b29c14
Author: zentol <s.motsu@web.de>
Authored: Thu Feb 18 10:37:49 2016 +0100
Committer: Till Rohrmann <trohrmann@apache.org>
Committed: Tue Feb 23 15:20:07 2016 +0100

----------------------------------------------------------------------
 .../main/java/org/apache/flink/api/java/io/AvroOutputFormat.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/77c1deed/flink-batch-connectors/flink-avro/src/main/java/org/apache/flink/api/java/io/AvroOutputFormat.java
----------------------------------------------------------------------
diff --git a/flink-batch-connectors/flink-avro/src/main/java/org/apache/flink/api/java/io/AvroOutputFormat.java
b/flink-batch-connectors/flink-avro/src/main/java/org/apache/flink/api/java/io/AvroOutputFormat.java
index e53874f..4d8313c 100644
--- a/flink-batch-connectors/flink-avro/src/main/java/org/apache/flink/api/java/io/AvroOutputFormat.java
+++ b/flink-batch-connectors/flink-avro/src/main/java/org/apache/flink/api/java/io/AvroOutputFormat.java
@@ -107,7 +107,7 @@ public class AvroOutputFormat<E> extends FileOutputFormat<E>
implements Serializ
 		int length = in.readInt();
 		if(length != 0) {
 			byte[] json = new byte[length];
-			in.read(json);
+			in.readFully(json);
 
 			Schema schema = new Schema.Parser().parse(new String(json));
 			setSchema(schema);


Mime
View raw message