Re: Storm topology running in flink.

2018-05-11 Thread Fabian Hueske
Hi, >From the dev perspective there hasn't been done much on that component since a long time [1]. Are there any users of this feature on the user list and can comment on how it works for them? Best, Fabian [1] https://github.com/apache/flink/commits/master/flink-contrib/flink-storm 2018-05-11

Re: Storm topology running in flink.

2018-05-11 Thread m@xi
Hello there, I have storm code and I need to run it. If possible I would like to run it with Flink. Is this possible and this feature stable now? Best, Max -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: Storm topology running in flink.

2017-06-15 Thread yunfan123
That returns a String specific the resource path. Any suggestion about this? What I want is copy the resource to specific path in task manger, and pass the specific path to my operator. -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Storm-to

Re: Storm topology running in flink.

2017-06-15 Thread Aljoscha Krettek
What would getUserResourceDir() return? In general, Flink devs are very reluctant when adding new methods to such central interfaces because it’s not easy to fix them if they’re broken, unneeded. Best, Aljoscha > On 15. Jun 2017, at 12:40, yunfan123 wrote: > > It seems ok, but flink-storm not

Re: Storm topology running in flink.

2017-06-15 Thread yunfan123
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

Re: Storm topology running in flink.

2017-06-15 Thread Aljoscha Krettek
Hi, 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