This is an automated email from the ASF dual-hosted git repository. sijie pushed a commit to branch branch-2.1 in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git
The following commit(s) were added to refs/heads/branch-2.1 by this push: new acd77a0 leak assign schema in MessageImpl constructor (#2439) acd77a0 is described below commit acd77a0fe6f09de1919040b65a90fb145f7f1bfa Author: Jia Zhai <jiaz...@users.noreply.github.com> AuthorDate: Fri Aug 24 11:42:55 2018 +0800 leak assign schema in MessageImpl constructor (#2439) --- .../src/main/java/org/apache/pulsar/client/impl/MessageImpl.java | 1 + 1 file changed, 1 insertion(+) diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageImpl.java index 5ea8bfe..96b68c1 100644 --- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageImpl.java +++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageImpl.java @@ -155,6 +155,7 @@ public class MessageImpl<T> implements Message<T> { this.cnx = null; this.payload = payload; this.properties = Collections.unmodifiableMap(properties); + this.schema = schema; } public static MessageImpl<byte[]> deserialize(ByteBuf headersAndPayload) throws IOException {