Hi Matthias, Of course, here is the package that contains the example's source classes. https://github.com/mbalassi/flink/tree/storm-backup/flink-staging/flink-streaming/flink-storm-examples/src/main/java/org/apache/flink/stormcompatibility/singlejoin It is mostly a copy-paste of SimpleJoin from storm-starter, though, I separated the spouts and the join bolt from the rest of the topology. I would be happy, if you could fix it. Probably I'm overlooking something.
Peter 2015-05-27 17:13 GMT+02:00 Matthias J. Sax <mj...@informatik.hu-berlin.de>: > Hi Peter, > > Thanks a lot for your feedback. It's exiting to see, that somebody uses > the layer already. :) > > The current prototype is going to be merged soon. However, I am more > than happy to extend the functionality of the layer. Can you please > share your example with me, so I can see what the problem is and fix it? > > I am pretty sure, that the fix will be merged later on, too. There are > many other limitation in the layer. Right now, it is still in beta state. > ;) > > -Matthias > > > On 05/27/2015 03:48 PM, Szabó Péter wrote: > > Hey everyone, > > > > I experimented with the Storm compatibility layer Matthias wrote, and ran > > some Storm examples on Flink. I found that Storm's SimpleJoin example > does > > not work. I suppose it is because of the multiple input streams. I'm > > willing to add another example instead. > > Right now, I'm getting it through Aljoscha's streaming refactor. > > > > Peter > > > >
