Re: Bug fix release 0.9.1

Hi, I did a (thin) fix for FLINK-2286 Window ParallelMerge sometimes swallows elements of the last window and also added a PR . Regards, Gábor On Thu, Aug 6, 2015 at 10:07 AM Maximilian Michels wrote: > Hi, > > The following commits have been added to

Re: Replacing Checkpointed interface with field annotations

Wow, this looks pretty concise. I really like it! On Mon, Jun 29, 2015 at 3:27 PM Gyula Fóra wrote: > Hey all! > > Just to add something new to the end of the discussion list. After some > discussion with Seif, and Paris, I have added a commit that replaces the > use of the Checkpointed interfac

Re: New project website

Great! It looks way better than the current site :) On Mon, May 11, 2015 at 1:28 PM Stephan Ewen wrote: > I think we may have to remove the term "Language Integrated Queries", I > think that is trademarked by Microsoft. > > Otherwise, +1 > > On Mon, May 11, 2015 at 1:19 PM, Maximilian Michels >

Re: [Gelly] Vertex-centric iteration updateVertex does not get called

Hey, Thank you both for your help :) I was missing this point in the Pregel model. I thought it would be expected to receive empty message iterators. Yes, I know it is not the best use-case for vertex-centric iteration as there are well-defined steps, and also know the Flink examples. I only want

[Gelly] Vertex-centric iteration updateVertex does not get called

Hi all, I am implementing a simple triangle counting example for a workshop with vertex-centric iteration and I found that the updateVertex method only gets called if there are new messages for that vertex. Is it the expected behavior? I know that the iteration should stop for the given vertex wh

Re: Major Streaming refactoring

Great! That was really needed. On Mon, Apr 13, 2015 at 9:36 PM Gyula Fóra wrote: > Dear All, > > Today I did a major refactoring of some streaming components, with a lot of > class renamings and some package restructuring. > > https://github.com/apache/flink/pull/594 > > 1. I refactored the inte

Re: Website documentation minor bug

Great! Thanks Max! On Wed, Mar 18, 2015 at 11:34 AM Maximilian Michels wrote: > Alright, changed it for the master. I think it makes the docs much more > pleasant to read. > > http://ci.apache.org/projects/flink/flink-docs-master/ > > On Wed, Mar 18, 2015 at 9:26 AM, Herm

Re: Website documentation minor bug

te like in > > http://flink.apache.org/community.html > > > > On Tue, Mar 10, 2015 at 4:03 PM, Maximilian Michels > > wrote: > > > > > Thanks for the feedback. Merged. > > > > > > On Tue, Mar 10, 2015 at 11:34 AM, Márton Bal

Streaming topology tests to use CollectionEnvironment

Hey all, Currently streaming topology tests use TestStreamEnvironment and static collections as sinks for assertion. I see that that the batch API tests use CollectionEnvironment for this purpose. Is there any reason streaming do not have something like that? I think it would be more compact and

Re: [DISCUSS] Name of Expression API and DataSet abstraction

+1 for DataTable On Mon, Mar 16, 2015 at 4:11 PM Till Rohrmann wrote: > +1 for DataTable > > On Mon, Mar 16, 2015 at 10:34 AM, Márton Balassi > > wrote: > > > +1 for Max's suggestion. > > > > On Mon, Mar 16, 2015 at 10:32 AM, Ufuk Celebi wrote: > > > > > On Fri, Mar 13, 2015 at 6:08 PM, Maximi

Re: [DISCUSS] Issues with heterogeneity of the code

+1 for the stricter Java code styles. We should not forget about providing code formatter settings for Eclipse and Intellij IDEA (as mentioned above). That would help a lot. (Of course if we'll use Google Code Style, they already provide such files

Re: Website documentation minor bug

ed changes. > >> > >> New > >> > >> > >> Old > >> > >> > >> > >> > >> If there are no objections, I will merge this by the end of the day. > >> > >> Best regards, > >> Max > >

Re: Website documentation minor bug

; > Can someone help me with this? > > > > > > On Sun, Mar 8, 2015 at 9:52 PM Stephan Ewen wrote: > > > > > >> I agree, it is not optimal. > > >> > > >> What would be a better way to do this? Have the main navigati

Re: Website documentation minor bug

o take a stab at this? > > On Sun, Mar 8, 2015 at 7:08 PM, Hermann Gábor > wrote: > > > Hey, > > > > Currently following an anchor link (e.g. #transformations > > < > > http://ci.apache.org/projects/flink/flink-docs-master/ > programming_guide.html#tra

Website documentation minor bug

Hey, Currently following an anchor link (e.g. #transformations ) results in the header occupying the top of the page, thus the title and some of the first lines cannot be seen. This is not a big deal, but

[DISCUSS] Documentation Java/Scala order

Hey all, The default language for the source codes in the documentation is Java (see the Programming Guide ), but in blog posts (like Introducing Flink Streaming

Re: Gelly is in!

Cool! Congrats! :) On Wed Feb 11 2015 at 12:45:17 Max Michels wrote: > Great contribution! Thanks to everyone who made it possible. > > On Wed, Feb 11, 2015 at 12:21 PM, Gyula Fóra wrote: > > Great! > > Thank you guys :) > > > > On Wed, Feb 11, 2015 at 12:17 PM, Vasiliki Kalavri < > > vasilikik

Re: Events not received

In our case we are actually waiting for some kind of acknowledgement events, so it is easily verifiable if there are any further events. We check whether everything has been acknowledged. On Tue Feb 10 2015 at 9:42:14 AM Ufuk Celebi wrote: > > On 10 Feb 2015, at 02:13, Hermann Gábor

Re: Events not received

lew > it up quite a bit when I "merged" it with the InputGate. I think I will > revert that soon.) > > On 09 Feb 2015, at 15:06, Hermann Gábor wrote: > > > Hi all, > > > > We've been trying to use events for two-way communication, but it seems > >

Events not received

Hi all, We've been trying to use events for two-way communication, but it seems like some of the backward events (at a BufferReader) are not sent at all if the connection is not initialized yet (i.e. the given input channel is UNKNOWN). Is there a way to make sure the events get to the destinatio

Streaming fault tolerance with event sending

Hey, We've been implementing a simple Storm-like fault tolerance system with persisting source records and keeping track of all the records (whether they've been processed), and replaying them if they fail. The straightforward way to do this was creating a special AbstractJobVertex (and AbstractIn

Re: Question on Streaming Dependency

Hey! As I can see, it was mistakenly added there during summer (probably by interns working on connectors). Thanks for the fix! Regards, Gábor On Sat, Jan 10, 2015 at 4:50 PM, Stephan Ewen wrote: > Just figured out that it is a transitive dependency of the streaming > connectors. Will move it