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
