flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Szabó Péter <nemderogator...@gmail.com>
Subject Re: Storm compatibility layer currently does not support Storm's SimpleJoin example
Date Thu, 28 May 2015 07:37:26 GMT
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 <mjsax@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
> >
>
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message