[
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)
