Re: Master test stability poor

2016-05-23 Thread Ufuk Celebi
Caches have been cleared again (see https://issues.apache.org/jira/browse/INFRA-11773) The first time did not help. This second request was more an act of desparation. :-( Let's see what happens now. On Wed, Apr 27, 2016 at 3:24 PM, Maximilian Michels wrote: > +1 for making an effort to tackle t

Re: Master test stability poor

2016-05-23 Thread Chesnay Schepler
If this doesn't work we may want to think about disabling the problematic profile temporarily. On 23.05.2016 09:53, Ufuk Celebi wrote: Caches have been cleared again (see https://issues.apache.org/jira/browse/INFRA-11773) The first time did not help. This second request was more an act of desp

Re: Master test stability poor

2016-05-23 Thread Robert Metzger
We could also try to disable the caching of the .m2 directory (I suspect that it contains broken jar files). The problem is that it this will make the builds slower on travis because we need to download more. On Mon, May 23, 2016 at 10:18 AM, Chesnay Schepler wrote: > If this doesn't work we ma

[jira] [Created] (FLINK-3953) Surefire plugin executes unit tests twice

2016-05-23 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-3953: - Summary: Surefire plugin executes unit tests twice Key: FLINK-3953 URL: https://issues.apache.org/jira/browse/FLINK-3953 Project: Flink Issue Type:

Re: Master test stability poor

2016-05-23 Thread Chesnay Schepler
if we disable caching, let it run for 1 build and enable it again, will that effectively clear the .m2 cache? On 23.05.2016 12:00, Robert Metzger wrote: We could also try to disable the caching of the .m2 directory (I suspect that it contains broken jar files). The problem is that it this will

[jira] [Created] (FLINK-3954) Installing Flink on EMR using EMR bootstrap action

2016-05-23 Thread Akshay Shingote (JIRA)
Akshay Shingote created FLINK-3954: -- Summary: Installing Flink on EMR using EMR bootstrap action Key: FLINK-3954 URL: https://issues.apache.org/jira/browse/FLINK-3954 Project: Flink Issue Ty

[jira] [Created] (FLINK-3955) Change Table.toSink() to Table.writeToSink()

2016-05-23 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-3955: Summary: Change Table.toSink() to Table.writeToSink() Key: FLINK-3955 URL: https://issues.apache.org/jira/browse/FLINK-3955 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-3956) Make FileInputFormats in Streaming independent from the Configuration object

2016-05-23 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-3956: - Summary: Make FileInputFormats in Streaming independent from the Configuration object Key: FLINK-3956 URL: https://issues.apache.org/jira/browse/FLINK-3956 Project:

[jira] [Created] (FLINK-3957) Breaking API changes for Flink 2.0

2016-05-23 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3957: - Summary: Breaking API changes for Flink 2.0 Key: FLINK-3957 URL: https://issues.apache.org/jira/browse/FLINK-3957 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-3958) Access to MetricRegistry doesn't have proper synchronization in some classes

2016-05-23 Thread Ted Yu (JIRA)
Ted Yu created FLINK-3958: - Summary: Access to MetricRegistry doesn't have proper synchronization in some classes Key: FLINK-3958 URL: https://issues.apache.org/jira/browse/FLINK-3958 Project: Flink

[jira] [Created] (FLINK-3959) Remove implicit sinks

2016-05-23 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-3959: --- Summary: Remove implicit sinks Key: FLINK-3959 URL: https://issues.apache.org/jira/browse/FLINK-3959 Project: Flink Issue Type: Sub-task Components:

Re: buffering in operators, implementing statistics

2016-05-23 Thread Aljoscha Krettek
Hi, no such changes are planned right now. The separaten between the keys is very strict in order to make the windowing state re-partitionable so that we can implement dynamic rescaling of the parallelism of a program. The WindowAll is only used for specific cases where you need a Trigger that see

Re: buffering in operators, implementing statistics

2016-05-23 Thread Stavros Kontopoulos
Hey Aljoscha, Thnax for the useful comments. I have recently looked at spark sketches: http://www.slideshare.net/databricks/sketching-big-data-with-spark-randomized-algorithms-for-largescale-data-analytics So there must be value in this effort. In my experience counting in general is a common need

Re: Janino related question

2016-05-23 Thread Gábor Horváth
Hi, Unfortunately I found another mysterious issue. If I compile the generated code using Janino, the readObject method will not triggered after an object of that class is deserialized. In case I am compiling the class using Oracle JDK, the readObject method will be triggered as expected. Did any

[jira] [Created] (FLINK-3960) EventTimeCheckpointingITCase fails with a segmentation fault

2016-05-23 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-3960: - Summary: EventTimeCheckpointingITCase fails with a segmentation fault Key: FLINK-3960 URL: https://issues.apache.org/jira/browse/FLINK-3960 Project: Flink

[jira] [Created] (FLINK-3961) Possibility to write output to multiple locations based on partitions

2016-05-23 Thread Kirsti Laurila (JIRA)
Kirsti Laurila created FLINK-3961: - Summary: Possibility to write output to multiple locations based on partitions Key: FLINK-3961 URL: https://issues.apache.org/jira/browse/FLINK-3961 Project: Flink