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