flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Boyang Jerry Peng (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-2610) run method in AbstractStormSpoutWrapper causes NPE
Date Wed, 02 Sep 2015 18:46:47 GMT
Boyang Jerry Peng created FLINK-2610:
----------------------------------------

             Summary: run method in AbstractStormSpoutWrapper causes NPE
                 Key: FLINK-2610
                 URL: https://issues.apache.org/jira/browse/FLINK-2610
             Project: Flink
          Issue Type: Bug
            Reporter: Boyang Jerry Peng


In the method: 

public final void run(final SourceContext<OUT> ctx) throws Exception

The line:

this.spout.open(null,
				StormWrapperSetupHelper
				.convertToTopologyContext((StreamingRuntimeContext) super.getRuntimeContext(), true),
				new SpoutOutputCollector(this.collector));

Will cause a NullPointerException since the the first argument of spout.open cannot be null.
 In Storm, this is where stormconfs are passed and the map that gets passed in is never null
thus null is never checked.  I observed this problem when using a KafkaSpout in a Storm topology
I am trying to run on top of flink





--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message