[jira] [Created] (FLINK-1475) Minimize log output of yarn test cases

2015-02-04 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-1475: Summary: Minimize log output of yarn test cases Key: FLINK-1475 URL: https://issues.apache.org/jira/browse/FLINK-1475 Project: Flink Issue Type: Bug

Re: Drafting a roadmap for Flink

2015-02-04 Thread Henry Saputra
Thanks Stephan, Kostas, sounds good to me On Wed, Feb 4, 2015 at 2:57 AM, Kostas Tzoumas ktzou...@apache.org wrote: Yeah, this is something that nobody is working on AFAIK and not a major focus of the project. I moved it to the interesting projects page (and cleaned up the page a bit removing

Re: [jira] [Created] (FLINK-1462) Add documentation guide for the graph API

2015-02-04 Thread Ufuk Celebi
I think it is GitHub flavored markdown. GH has a reference with the additions. On Wednesday, February 4, 2015, Vasia Kalavri (JIRA) j...@apache.org wrote: [

Re: Drafting a roadmap for Flink

2015-02-04 Thread Kostas Tzoumas
Yeah, this is something that nobody is working on AFAIK and not a major focus of the project. I moved it to the interesting projects page (and cleaned up the page a bit removing streaming, tez, and mahout as these are ongoing efforts). On Wed, Feb 4, 2015 at 9:34 AM, Stephan Ewen se...@apache.org

Cluster execution - Jobmanager unreachable

2015-02-04 Thread Chesnay Schepler
Hello, I'm trying to run python jobs with the latest master on a cluster and get the following exception: Error: The program execution failed: JobManager not reachable anymore. Terminate waiting for job answer. org.apache.flink.client.program.ProgramInvocationException: The program

Re: Sorting of fields

2015-02-04 Thread Timo Walther
Ok, I found an earlier discussion about it. Sorry for the mail. However, I think this is a very important feature and I should be added soon. On 04.02.2015 14:38, Timo Walther wrote: Hey, is it correct that we currently do not support sorting without any grouping? I had this question by 2

January 2015 in the Flink community

2015-02-04 Thread Kostas Tzoumas
Here is a digestible read on some January activity in the Flink community: http://flink.apache.org/news/2015/02/04/january-in-flink.html Highlights: - Flink 0.8.0 was released - The Flink community published a technical roadmap for 2015 - Flink was used to scale matrix factorization to

Re: Sorting of fields

2015-02-04 Thread Fabian Hueske
I just merged support for local output sorting yesterday :-) This allows to sort the data before it is given to the OutputFormat. It is done like this: myData.write(myOF).sortLocalOutput(1, Order.ASCENDING); See the programming guide for details (only in master, not online). Full sorting can be

[jira] [Created] (FLINK-1473) Simplify SplittableIterator interface

2015-02-04 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1473: - Summary: Simplify SplittableIterator interface Key: FLINK-1473 URL: https://issues.apache.org/jira/browse/FLINK-1473 Project: Flink Issue Type: Task