Failing Test

2016-04-01 Thread Matthias J. Sax
Anyone seen this before? One-time thing or test instability? > ClusterShutdownITCase.testClusterShutdown:71 assertion failed: timeout > (29848225634 nanoseconds) during expectMsgClass waiting for class > org.apache.flink.runtime.clusterframework.messages.StopClusterSuccessful -Matthias sign

Re: Failing Test

2016-04-01 Thread Ufuk Celebi
Hey Matthias, the test has been only recently added with the resource management refactoring. It's probably just a too aggressive timeout for Travis. @Max: Did you ever see this fail? – Ufuk On Fri, Apr 1, 2016 at 9:24 AM, Matthias J. Sax wrote: > Anyone seen this before? One-time thing or tes

[jira] [Created] (FLINK-3686) resourcemanager.ClusterShutdownITCase sometimes fails

2016-04-01 Thread Nikolaas Steenbergen (JIRA)
Nikolaas Steenbergen created FLINK-3686: --- Summary: resourcemanager.ClusterShutdownITCase sometimes fails Key: FLINK-3686 URL: https://issues.apache.org/jira/browse/FLINK-3686 Project: Flink

[jira] [Created] (FLINK-3687) runtime.leaderelection.ZooKeeperLeaderElectionTest fails

2016-04-01 Thread Nikolaas Steenbergen (JIRA)
Nikolaas Steenbergen created FLINK-3687: --- Summary: runtime.leaderelection.ZooKeeperLeaderElectionTest fails Key: FLINK-3687 URL: https://issues.apache.org/jira/browse/FLINK-3687 Project: Flink

[jira] [Created] (FLINK-3688) ClassCastException in StreamRecordSerializer when WindowOperator.trigger() is called and TimeCharacteristic = ProcessingTime

2016-04-01 Thread Konstantin Knauf (JIRA)
Konstantin Knauf created FLINK-3688: --- Summary: ClassCastException in StreamRecordSerializer when WindowOperator.trigger() is called and TimeCharacteristic = ProcessingTime Key: FLINK-3688 URL: https://issues.apa

Re: Failing Test

2016-04-01 Thread Maximilian Michels
Hi Matthias, Thanks for spotting the test failure. It's actually a bug in the code and not a test problem. Fixing it. Cheers, Max On Fri, Apr 1, 2016 at 9:33 AM, Ufuk Celebi wrote: > Hey Matthias, > > the test has been only recently added with the resource management > refactoring. It's probabl

[jira] [Created] (FLINK-3689) JobManager blocks cluster shutdown when not connected to ResourceManager

2016-04-01 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-3689: - Summary: JobManager blocks cluster shutdown when not connected to ResourceManager Key: FLINK-3689 URL: https://issues.apache.org/jira/browse/FLINK-3689 Proj

Re: [VOTE] Release Apache Flink 1.0.1 (RC1)

2016-04-01 Thread Aljoscha Krettek
I ran the usual tests and the release seems fine. A user, however, found this bug which seems to be a blocker: https://issues.apache.org/jira/browse/FLINK-3688?jql=project%20%3D%20FLINK Should we maybe wait for the fix and then to another RC? On Thu, 31 Mar 2016 at 18:10 Ufuk Celebi wrote: > De

Announcing S-link-y

2016-04-01 Thread Bobby Evans
Today I am happy to announce a prototype of an Apache Storm based backend for Apache Flink called S-link-y.  Storm offers a number of advantages over Flink including enterprise level security and a distributed cache with in place updating.  The Flink front end offers both batch processing APIs a

CEP blog post

2016-04-01 Thread Till Rohrmann
Hi Flink community, I've written a short blog [1] post about Flink's new CEP library which basically showcases its functionality using a monitoring example. I would like to publish the post on the flink.apache.org blog next week, if nobody objects. Feedback is highly appreciated :-) [1] https://d

Re: Announcing S-link-y

2016-04-01 Thread Aljoscha Krettek
perfect On Fri, 1 Apr 2016 at 15:51 Bobby Evans wrote: > Today I am happy to announce a prototype of an Apache Storm based backend > for Apache Flink called S-link-y. Storm offers a number of advantages over > Flink including enterprise level security and a distributed cache with in > place upd

[jira] [Created] (FLINK-3690) Create documentation on the new ResourceManager component

2016-04-01 Thread Henry Saputra (JIRA)
Henry Saputra created FLINK-3690: Summary: Create documentation on the new ResourceManager component Key: FLINK-3690 URL: https://issues.apache.org/jira/browse/FLINK-3690 Project: Flink Issue

Re: Failing Test

2016-04-01 Thread Maximilian Michels
Fixed with the resolution of https://issues.apache.org/jira/browse/FLINK-3689. On Fri, Apr 1, 2016 at 12:40 PM, Maximilian Michels wrote: > Hi Matthias, > > Thanks for spotting the test failure. It's actually a bug in the code > and not a test problem. Fixing it. > > Cheers, > Max > > On Fri, Apr

[jira] [Created] (FLINK-3691) Extend AvroInputFormat to support Avro GenericRecord

2016-04-01 Thread Gna Phetsarath (JIRA)
Gna Phetsarath created FLINK-3691: - Summary: Extend AvroInputFormat to support Avro GenericRecord Key: FLINK-3691 URL: https://issues.apache.org/jira/browse/FLINK-3691 Project: Flink Issue Ty