Jagadish created SAMZA-1754:
-------------------------------
Summary: Improve validation error messages in StreamSpec
Key: SAMZA-1754
URL: https://issues.apache.org/jira/browse/SAMZA-1754
Project: Samza
Issue Type: Bug
Reporter: Jagadish
Often, there are validation failures due to a misconfigured StreamSpec. Here's
one such example:
{code}
Caused by: java.lang.IllegalArgumentException: Identifier 'systemName' is
'null'. It must match the expression [A-Za-z0-9_-]+
at
org.apache.samza.system.StreamSpec.validateLogicalIdentifier(StreamSpec.java:245)
at org.apache.samza.system.StreamSpec.<init>(StreamSpec.java:163)
at org.apache.samza.system.StreamSpec.<init>(StreamSpec.java:140)
at
org.apache.samza.runtime.AbstractApplicationRunner.getStreamSpec(AbstractApplicationRunner.java:119)
at
org.apache.samza.runtime.AbstractApplicationRunner.getStreamSpec(AbstractApplicationRunner.java:100)
at
org.apache.samza.runtime.AbstractApplicationRunner.getStreamSpec(AbstractApplicationRunner.java:65)
at
org.apache.samza.operators.StreamGraphImpl.getInputStream(StreamGraphImpl.java:91)
at
org.apache.samza.operators.StreamGraphImpl.getInputStream(StreamGraphImpl.java:117)
at
com.linkedin.actioncommon.ams.samza.AccountManagementStreamApplication.init(AccountManagementStreamApplication.java:31)
at
org.apache.samza.runtime.AbstractApplicationRunner.getExecutionPlan(AbstractApplicationRunner.java:131)
at
org.apache.samza.runtime.AbstractApplicationRunner.getExecutionPlan(AbstractApplicationRunner.java:124)
at
org.apache.samza.runtime.LocalApplicationRunner.run(LocalApplicationRunner.java:152)
{code}
The error message should have adequate context:
1. What was the topicName, streamId, numPartitions, physicalName, numPartitions
in the StreamSpec being validated?
2. Which validation failed? was any of the component null or did it not match
the regex
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
