[jira] [Created] (FLINK-3716) Kafka08ITCase.testFailOnNoBroker() timing out before it has a chance to pass

2016-04-07 Thread Todd Lisonbee (JIRA)
Todd Lisonbee created FLINK-3716: Summary: Kafka08ITCase.testFailOnNoBroker() timing out before it has a chance to pass Key: FLINK-3716 URL: https://issues.apache.org/jira/browse/FLINK-3716 Project: F

Re: Broken links after doc resturcturing

2016-04-07 Thread Stephan Ewen
Hey Matthias! The mailing list and feature requests are getting super many, hard to keep up and fix things within days... Do you think you could fix those links? As a simple approach, I would suggest to - Truncate the history to drop everything earlier than "Flink" days (in your list before Ha

Re: Expected duration for cascading-flink tests?

2016-04-07 Thread Fabian Hueske
Hi Ken, I fixed the issues you reported and pushed a new version that depends on Flink 1.0.1 and Cascading 3.1-wip-56 to the master branch [1]. We will publish this branch soon as cascading-flink 0.2. Thanks for your help, Fabian [1] https://github.com/dataArtisans/cascading-flink/tree/master 2

Re: Broken links after doc resturcturing

2016-04-07 Thread Matthias J. Sax
Anyone? On 04/04/2016 05:06 PM, Matthias J. Sax wrote: > Hi, > > I just stepped through the whole blog. Some stuff can get fixed easily, > more links should just be removed, and for some I am not sure what to do > about (quite old stuff). > > I put my though about each broken link (or nothing if

[jira] [Created] (FLINK-3715) Move Accumulating/Discarding from Trigger to WindowOperator

2016-04-07 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3715: --- Summary: Move Accumulating/Discarding from Trigger to WindowOperator Key: FLINK-3715 URL: https://issues.apache.org/jira/browse/FLINK-3715 Project: Flink

[jira] [Created] (FLINK-3714) Add Support for "Allowed Lateness"

2016-04-07 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3714: --- Summary: Add Support for "Allowed Lateness" Key: FLINK-3714 URL: https://issues.apache.org/jira/browse/FLINK-3714 Project: Flink Issue Type: Sub-task

Re: Table API / SQL Queries and Code Generation

2016-04-07 Thread Gábor Horváth
Hi, Thank you for the responses! On 7 April 2016 at 12:38, Fabian Hueske wrote: > Hi Gabor, > > the Table API / SQL translator generates the code as String and ships the > String as member of the function object. > The code is compiled with Janino when the function is initialized in the > open(

Re: Table API / SQL Queries and Code Generation

2016-04-07 Thread Fabian Hueske
Hi Gabor, the Table API / SQL translator generates the code as String and ships the String as member of the function object. The code is compiled with Janino when the function is initialized in the open() method. So we are not shipping classes but compile the code at the worker. Not sure if this

[jira] [Created] (FLINK-3713) DisposeSavepoint message uses system classloader to discard state

2016-04-07 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3713: - Summary: DisposeSavepoint message uses system classloader to discard state Key: FLINK-3713 URL: https://issues.apache.org/jira/browse/FLINK-3713 Project: Flink

[jira] [Created] (FLINK-3712) YARN client dynamic properties are not passed correctly to the leader election service on the client

2016-04-07 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3712: - Summary: YARN client dynamic properties are not passed correctly to the leader election service on the client Key: FLINK-3712 URL: https://issues.apache.org/jira/browse/FLINK-37

Re: [DISCUSS] Macro-benchmarking for performance tuning and regression detection

2016-04-07 Thread Till Rohrmann
Hi Greg, I like the idea to have a macro-benchmarking suite to exactly test the points you've mentioned. If we don't have reliable performance numbers, then it will always be hard to tell whether an improvement makes sense or not (performance-wise). I think we already undertook a first attempt to