Re: Bug fix release 0.9.1

Hi, The following commits have been added to the release-0.9 branch since the 0.9.0 release: c7e8684 [FLINK-2229] Add equals() and hashCode() to ObjectArrayTypeInfo 451eb82 [FLINK-2280] GenericTypeComparator.compare() respects ascending flag acd4317 [FLINK-2353] Respect JobConfigurable interface

[jira] [Created] (FLINK-2490) Remove unwanted boolean check in function SocketTextStreamFunction.streamFromSocket

Huang Wei created FLINK-2490: Summary: Remove unwanted boolean check in function SocketTextStreamFunction.streamFromSocket Key: FLINK-2490 URL: https://issues.apache.org/jira/browse/FLINK-2490 Project: Fl

[jira] [Created] (FLINK-2491) Operators are not participating in state checkpointing in some cases

Robert Metzger created FLINK-2491: - Summary: Operators are not participating in state checkpointing in some cases Key: FLINK-2491 URL: https://issues.apache.org/jira/browse/FLINK-2491 Project: Flink

Re: FYI: Blog Post on Flink's Streaming Performance and Fault Tolerance

Thanks, Theo. Fixed the markup... On Wed, Aug 5, 2015 at 11:08 PM, Theodore Vasiloudis < theodoros.vasilou...@gmail.com> wrote: > Great post Stephan! A small note: the code for Google Dataflow does display > correctly for me, I'm getting < and > instead of <> > > On Wed, Aug 5, 2015 at 4:11 PM,

[jira] [Created] (FLINK-2492) Rename remaining runtime classes from "match" to "join"

Stephan Ewen created FLINK-2492: --- Summary: Rename remaining runtime classes from "match" to "join" Key: FLINK-2492 URL: https://issues.apache.org/jira/browse/FLINK-2492 Project: Flink Issue Typ

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: New failing Kafka Test

I think we are all eager for Robert's rework of the Kafka connector and tests... On Mon, Aug 3, 2015 at 12:38 AM, Matthias J. Sax < mj...@informatik.hu-berlin.de> wrote: > Hi, > > I hit a failing test KafkaITCase.bigRecordTestTopology > https://travis-ci.org/mjsax/flink/jobs/73807115 > > I know t

[jira] [Created] (FLINK-2493) Simplify names of example program JARs

Stephan Ewen created FLINK-2493: --- Summary: Simplify names of example program JARs Key: FLINK-2493 URL: https://issues.apache.org/jira/browse/FLINK-2493 Project: Flink Issue Type: Improvement

[ANNOUNCE] Apache Mahout 0.10.2 Release

The Apache Mahout PMC is pleased to announce the release of Mahout 0.10.2. Mahout's goal is to create an environment for quickly creating machine learning applications that scale and run on the highest performance parallel computation engines available. Mahout comprises an interactive environment a

[jira] [Created] (FLINK-2494) Fix StreamGraph getJobGraph bug

fangfengbin created FLINK-2494: -- Summary: Fix StreamGraph getJobGraph bug Key: FLINK-2494 URL: https://issues.apache.org/jira/browse/FLINK-2494 Project: Flink Issue Type: Bug Component