You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/05/04 20:53:05 UTC
[jira] [Commented] (SAMZA-1263) Samza Fluent: NPE is
streams.id.samza.system is missing
[ https://issues.apache.org/jira/browse/SAMZA-1263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15997414#comment-15997414 ]
ASF GitHub Bot commented on SAMZA-1263:
---------------------------------------
GitHub user jmakes opened a pull request:
https://github.com/apache/samza/pull/165
SAMZA-1263: Samza Fluent: NPE is streams.id.samza.system is missing
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/jmakes/samza samza-1263
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/samza/pull/165.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #165
----
commit c0cd13852ff063e15c3ebdb5bd419a7a5f43d61c
Author: Jacob Maes <jm...@linkedin.com>
Date: 2017-05-04T20:51:38Z
SAMZA-1263: Samza Fluent: NPE is streams.id.samza.system is missing
----
> Samza Fluent: NPE is streams.id.samza.system is missing
> -------------------------------------------------------
>
> Key: SAMZA-1263
> URL: https://issues.apache.org/jira/browse/SAMZA-1263
> Project: Samza
> Issue Type: Bug
> Reporter: Jake Maes
> Assignee: Jake Maes
>
> The reported error gives the user no clue as to what to do:
> {noFormat}
> org.apache.samza.SamzaException: Failed to run application
> at org.apache.samza.runtime.LocalApplicationRunner.run(LocalApplicationRunner.java:136)
> at com.linkedin.beam.runners.samza.runtime.fluent.FluentRuntime$RunnerTask.run(FluentRuntime.java:114)
> ... 1 more
> Caused by: java.lang.NullPointerException
> at org.apache.samza.system.StreamSpec.validateLogicalIdentifier(StreamSpec.java:200)
> at org.apache.samza.system.StreamSpec.<init>(StreamSpec.java:141)
> at org.apache.samza.system.StreamSpec.<init>(StreamSpec.java:120)
> at org.apache.samza.runtime.AbstractApplicationRunner.getStreamSpec(AbstractApplicationRunner.java:94)
> at org.apache.samza.runtime.AbstractApplicationRunner.getStreamSpec(AbstractApplicationRunner.java:76)
> at org.apache.samza.runtime.AbstractApplicationRunner.getStreamSpec(AbstractApplicationRunner.java:51)
> at org.apache.samza.operators.StreamGraphImpl.getInputStream(StreamGraphImpl.java:65)
> at com.linkedin.beam.runners.samza.runtime.fluent.translator.TranslationContext.getInputStream(TranslationContext.java:23)
> at com.linkedin.beam.runners.samza.runtime.fluent.translator.SourceDataSetTranslator.translate(SourceDataSetTranslator.java:9)
> at com.linkedin.beam.runners.samza.runtime.fluent.translator.SourceDataSetTranslator.translate(SourceDataSetTranslator.java:6)
> at com.linkedin.beam.runners.samza.runtime.fluent.translator.FluentTranslator.applyTranslator(FluentTranslator.java:64)
> at com.linkedin.beam.runners.samza.runtime.fluent.translator.FluentTranslator.access$200(FluentTranslator.java:18)
> at com.linkedin.beam.runners.samza.runtime.fluent.translator.FluentTranslator$1.visitDataSet(FluentTranslator.java:54)
> at com.linkedin.beam.runners.samza.ir.translator.IrGraph.visitTopologically(IrGraph.java:97)
> at com.linkedin.beam.runners.samza.runtime.fluent.translator.FluentTranslator.run(FluentTranslator.java:47)
> at com.linkedin.beam.runners.samza.runtime.fluent.translator.FluentTranslator.translate(FluentTranslator.java:43)
> at com.linkedin.beam.runners.samza.runtime.fluent.FluentRuntime$1.init(FluentRuntime.java:62)
> at org.apache.samza.runtime.AbstractApplicationRunner.getExecutionPlan(AbstractApplicationRunner.java:100)
> at org.apache.samza.runtime.LocalApplicationRunner.run(LocalApplicationRunner.java:112)
> ... 2 more
> Attachments
> {noFormat}
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)