flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Shinhyung Yang <shinhyung.y...@gmail.com>
Subject Working with storm compatibility layer
Date Sat, 09 Jan 2016 00:27:16 GMT
Howdies to everyone,

I'm trying to use the storm compatibility layer on Flink 0.10.1. The
original storm topology works fine on Storm 0.9.5 and I have
incorporated FlinkLocalCluster, FlinkTopologyBuilder, and
FlinkTopology classes according to the programming guide
(https://ci.apache.org/projects/flink/flink-docs-release-0.10/apis/storm_compatibility.html).
I'm running it on Oracle Java 8 (1.8.0_66-b17) on Centos 7 (7.2.1511).
What happens is, it seems to be going all the way to submitTopology
method without any problem, however it doesn't invoke open method of
Spout class but declareOutputFields method is called for multiple
times and the program exits silently. Do you guys have any idea what's
going on here or have any suggestions? If needed, then please ask me
for more information.

Thank you for reading.
With best regards,
Shinhyung Yang

Mime
View raw message