drill-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jacq...@apache.org
Subject [24/24] git commit: fix to use delimited for protobuf serialization
Date Thu, 22 May 2014 01:15:01 GMT
fix to use delimited for protobuf serialization


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

Branch: refs/heads/diagnostics2
Commit: c34a190fc5547a31876a58eaceb3d11eae8b3ca5
Parents: e2740df
Author: Jacques Nadeau <jacques@apache.org>
Authored: Wed May 21 18:14:26 2014 -0700
Committer: Jacques Nadeau <jacques@apache.org>
Committed: Wed May 21 18:14:26 2014 -0700

----------------------------------------------------------------------
 .../main/java/org/apache/drill/exec/cache/ProtoSerializable.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/c34a190f/exec/java-exec/src/main/java/org/apache/drill/exec/cache/ProtoSerializable.java
----------------------------------------------------------------------
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/cache/ProtoSerializable.java
b/exec/java-exec/src/main/java/org/apache/drill/exec/cache/ProtoSerializable.java
index 1538a85..0a2aa4a 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/cache/ProtoSerializable.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/cache/ProtoSerializable.java
@@ -45,12 +45,12 @@ public abstract class ProtoSerializable<V extends Message> extends
AbstractStrea
 
   @Override
   public void readFromStream(InputStream input) throws IOException {
-    obj = protoParser.parseFrom(input);
+    obj = protoParser.parseDelimitedFrom(input);
   }
 
   @Override
   public void writeToStream(OutputStream output) throws IOException {
-    obj.writeTo(output);
+    obj.writeDelimitedTo(output);
   }
 
   public static class PlanFragmentSerializable extends ProtoSerializable<PlanFragment>{


Mime
View raw message