I’m afraid the Storm compatibility layer has not been touched in a while and was never more than a pet project. Do you have an actual use case for running Storm topologies on top of Flink? Do be honest, I think it might be easier to simply port spouts to Flink SourceFunctions and bolts to a FlatMapFunction or a ProcessFunction.
It seems ok, but flink-storm not support storm codeDir.
I'm working on to make the flink-storm support the codeDir.
To support the code dir, I have to add a new funtion such as getUserResourceDir(may be return null) in flink RuntimeContext.
I know this may be a big change. What do you think of this?