Re: [ANNOUNCE] Introducing a feature branch for FLIP-6 (cluster management)

2016-08-03 Thread Aljoscha Krettek
+1 seems good On Wed, 3 Aug 2016 at 11:05 Stephan Ewen wrote: > Hi all! > > We would like to start working on FLIP-6. > > Because it is such a big change, I would like to start developing it > concurrently to the master branch for a while, and merge it once it is in a > stable state. > > For tha

Re: Introduction

2016-08-03 Thread Henry Saputra
Welcome! :) On Sunday, July 31, 2016, Neelesh Salian wrote: > Hello folks, > > I am Neelesh Salian; I recently joined the Flink community and I wanted to > take this opportunity to formally introduce myself. > > I have been working with the Hadoop and Spark ecosystems over the past two > years a

[ANNOUNCE] Introducing a feature branch for FLIP-6 (cluster management)

2016-08-03 Thread Stephan Ewen
Hi all! We would like to start working on FLIP-6. Because it is such a big change, I would like to start developing it concurrently to the master branch for a while, and merge it once it is in a stable state. For that reason, I'd like to fork a *feature branch "clustermanagement" *in the Flink r

Re: [VOTE] Release Apache Flink 1.1.0 (RC2)

2016-08-03 Thread Aljoscha Krettek
+1 I tested (on the last RC, which is also applicable here): - read README - did "mvn clean verify" - source contains no binaries - a few weeks back I extensively tested CEP and the Cassandra sink (we fixed stuff and now everything is good to go) - verify that quickstarts point to correct ver

Re: [VOTE] Release Apache Flink 1.1.0 (RC2)

2016-08-03 Thread Till Rohrmann
+1 from my side Checked LICENSE and NOTICE files Build and tests run for - Hadoop 2.6.0 SBT quickstarts work Basic stream SQL features work Metrics work with Ganglia, Graphite, JMX and StatsD On Wed, Aug 3, 2016 at 9:56 PM, Stephan Ewen wrote: > +1 from my side > > LICENSE and NOTICE files

Re: [VOTE] Release Apache Flink 1.1.0 (RC2)

2016-08-03 Thread Stephan Ewen
+1 from my side LICENSE and NOTICE files are good No binaries are in the release Build and tests run for - Hadoop 2.7.2 & Scala 2.11 (Maven 3.0.5) Tested Local standalone installation, logs, out, all good Tested different memory allocation schemes (heap/offheap) (preallocate/lazy allocate)

Re: Map Reduce Sorting

2016-08-03 Thread Hilmi Yildirim
Hi, I have another question. The reducer sorts its inputs before it starts with computation. Which sorting algorithm it is using? In Flink I found QuickSort, HeapSort and etc. Does the sorting algorithm benefit from pre-sorted partitions. For example, a MergeSort algorithm can sort the parti

[jira] [Created] (FLINK-4311) TableInputFormat fails when reused on next split

2016-08-03 Thread Niels Basjes (JIRA)
Niels Basjes created FLINK-4311: --- Summary: TableInputFormat fails when reused on next split Key: FLINK-4311 URL: https://issues.apache.org/jira/browse/FLINK-4311 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-4310) Move BinaryCompatibility Check plugin to relevant projects

2016-08-03 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4310: --- Summary: Move BinaryCompatibility Check plugin to relevant projects Key: FLINK-4310 URL: https://issues.apache.org/jira/browse/FLINK-4310 Project: Flink Issue