+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
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
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
+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
+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
+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)
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
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
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