[jira] [Created] (SAMZA-2270) Samza-sql: Fix ConsoleLoggingSystemFactory to handle null message value

["Aditya (JIRA)" <ji...@apache.org>]

Aditya created SAMZA-2270:
-----------------------------

             Summary: Samza-sql: Fix ConsoleLoggingSystemFactory to handle null message value
                 Key: SAMZA-2270
                 URL: https://issues.apache.org/jira/browse/SAMZA-2270
             Project: Samza
          Issue Type: Bug
            Reporter: Aditya
            Assignee: Aditya


Currently it fails with the below exception:

```Caused by: java.lang.NullPointerException
 at java.lang.String.<init>(String.java:566)
 at com.linkedin.samza.sql.ConsoleLoggingSystemFactory$LoggingSystemProducer.send(ConsoleLoggingSystemFactory.java:88)
 at org.apache.samza.system.SystemProducers.send(SystemProducers.scala:87)```

 

```public void send(String source, OutgoingMessageEnvelope envelope) {
 String msg = String.format("OutputStream:%s Key:%s Value:%s", envelope.getSystemStream(), envelope.getKey(),
 new String((byte[]) envelope.getMessage()));```



--
This message was sent by Atlassian JIRA
(v7.6.14#76016)