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 <[email protected]> Authored: Wed May 21 18:14:26 2014 -0700 Committer: Jacques Nadeau <[email protected]> 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>{
