[jira] [Closed] (FLINK-2610) run method in AbstractStormSpoutWrapper causes NPE

["Matthias J. Sax (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-2610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Matthias J. Sax closed FLINK-2610.
----------------------------------
    Resolution: Duplicate

Not all features are supported yet. See here for details https://github.com/apache/flink/blob/master/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/README.md

Flink-2525 will be resolved soon. There is already a PR.

> 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.  I will have a fix for this soon



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