[incubator-pulsar] branch master updated: Handle NPE for output producer is null for function (#1590)

[mmerli]

This is an automated email from the ASF dual-hosted git repository.

mmerli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 9d19a0e  Handle NPE for output producer is null for function (#1590)
9d19a0e is described below

commit 9d19a0ea112d192621d464e708910e2587705bd0
Author: Rajan Dhabalia <rdhaba...@apache.org>
AuthorDate: Mon Apr 16 14:58:36 2018 -0700

    Handle NPE for output producer is null for function (#1590)
---
 .../main/java/org/apache/pulsar/functions/api/utils/DefaultSerDe.java   | 1 +
 .../pulsar/functions/instance/processors/AtLeastOnceProcessor.java      | 2 +-
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/utils/DefaultSerDe.java
 
b/pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/utils/DefaultSerDe.java
index 543823d..1fc9a49 100644
--- 
a/pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/utils/DefaultSerDe.java
+++ 
b/pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/utils/DefaultSerDe.java
@@ -36,6 +36,7 @@ public class DefaultSerDe implements SerDe<Object> {
             Integer.class,
             Double.class,
             Long.class,
+            Boolean.class,
             String.class,
             Short.class,
             Byte.class,
diff --git 
a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/processors/AtLeastOnceProcessor.java
 
b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/processors/AtLeastOnceProcessor.java
index 38c1015..c8fecbf 100644
--- 
a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/processors/AtLeastOnceProcessor.java
+++ 
b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/processors/AtLeastOnceProcessor.java
@@ -54,7 +54,7 @@ public class AtLeastOnceProcessor extends 
MessageProcessorBase {
 
     @Override
     public void sendOutputMessage(InputMessage inputMsg, MessageBuilder 
outputMsgBuilder) {
-        if (null == outputMsgBuilder) {
+        if (null == outputMsgBuilder || null == producer) {
             inputMsg.ack();
             return;
         }

-- 
To stop receiving notification emails like this one, please contact
mme...@apache.org.