[ https://issues.apache.org/jira/browse/SAMZA-2143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Daniel Nishimura closed SAMZA-2143. ----------------------------------- > NPE in CoordinatorStreamMessage#equals and some clean-up to > CoordinatorStreamSystemConsumer > ------------------------------------------------------------------------------------------- > > Key: SAMZA-2143 > URL: https://issues.apache.org/jira/browse/SAMZA-2143 > Project: Samza > Issue Type: Bug > Affects Versions: 1.1 > Reporter: Daniel Nishimura > Assignee: Daniel Nishimura > Priority: Major > Time Spent: 0.5h > Remaining Estimate: 0h > > 1) NPE exposed in CoordinatorStreamMessage#equals now that the metadata store > allows arbitrary messages to be stored in the coordinator stream. See below > for example NPE stack trace. > Example NPE error: > {code:java} > Exception in thread "main" org.apache.samza.SamzaException: Failed to run > application > at > org.apache.samza.runtime.RemoteApplicationRunner.run(RemoteApplicationRunner.java:79) > at > org.apache.samza.runtime.ApplicationRunnerUtil.invoke(ApplicationRunnerUtil.java:54) > at > org.apache.samza.runtime.ApplicationRunnerMain.main(ApplicationRunnerMain.java:53) > Caused by: org.apache.samza.SamzaException: java.lang.NullPointerException > at > org.apache.samza.coordinator.stream.CoordinatorStreamSystemConsumer.bootstrap(CoordinatorStreamSystemConsumer.java:200) > at org.apache.samza.job.JobRunner.run(JobRunner.scala:107) > at > org.apache.samza.runtime.RemoteApplicationRunner.lambda$run$0(RemoteApplicationRunner.java:76) > at java.util.ArrayList.forEach(ArrayList.java:1257) > at > org.apache.samza.runtime.RemoteApplicationRunner.run(RemoteApplicationRunner.java:73) > ... 2 more > Caused by: java.lang.NullPointerException > at > org.apache.samza.coordinator.stream.messages.CoordinatorStreamMessage.equals(CoordinatorStreamMessage.java:315) > at java.util.HashMap.removeNode(HashMap.java:820) > at java.util.HashMap.remove(HashMap.java:799) > at java.util.HashSet.remove(HashSet.java:236) > at > org.apache.samza.coordinator.stream.CoordinatorStreamSystemConsumer.bootstrap(CoordinatorStreamSystemConsumer.java:181) > ... 6 more > {code} > 2) In CoordinatorStreamSystemConsumer, remove unused getBootstrappedStream > overloaded method and unit test the appropriate method that's actually used > in non-test code. -- This message was sent by Atlassian Jira (v8.3.2#803003)