Details
-
Bug
-
Status: Open
-
Major
-
Resolution: Unresolved
-
None
-
None
-
None
-
None
Description
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()));```
