Commits

Commits on Sep 17, 2014

[FLINK-1097] Fixed multiple slf4j bindings when using Hadoop2
tillrohrmann
committedSep 17, 2014

Commits on Sep 16, 2014

Update CONTRIBUTORS file
uce
committedSep 16, 2014
Fix typo in CONTRIBUTORS
uce
committedSep 16, 2014

Commits on Sep 11, 2014

[Tools] Minor fixes in release script
uce
committedSep 11, 2014

Commits on Sep 9, 2014

Fix typo in package LICENSE
uce
committedSep 9, 2014

Commits on Sep 8, 2014

[FLINK-925] Extended for distinct operator and added test cases
fhueske
committedSep 8, 2014
[FLINK-925] Support KeySelector function returning Tuple types

tobwiens
authored and
fhueske
committedSep 8, 2014

Commits on Sep 7, 2014

[FLINK-1063] Revert race introducing commit
uce
committedSep 7, 2014

Commits on Sep 6, 2014

[FLINK-629] Updated getFieldNotNull usage and added it to TupleSerializers

mbalassi
authored and
fhueske
committedSep 6, 2014
[FLINK-629] getFieldNotNull added to Tuple and updated Aggregators and Comparators to use that where appropriate

gyfora
authored and
fhueske
committedSep 6, 2014
Updated documentation figure: FlinkOnYarn.svg

skunert
authored and
fhueske
committedSep 6, 2014
[FLINK-1017] Add documentation for execution parallelism

Hung Chang
authored and
fhueske
committedSep 6, 2014

Commits on Sep 5, 2014

[FLINK-1086] Replace JCL with SLF4J and Log4j with LOGBack

tillrohrmann
authored and
uce
committedSep 5, 2014

Commits on Sep 4, 2014

Fix DeltaIteration Bug with Immutable Types
aljoscha
committedSep 4, 2014
Disable merging of Iteration Aux Tasks
aljoscha
committedSep 4, 2014

Commits on Sep 2, 2014

Default generic serializer is Avro. Minor improvements in KryoSerializer. Add mini benchmark for Avro/Kryo.
StephanEwen
committedSep 2, 2014
[FLINK-610] Added KryoSerializer

tillrohrmann
authored and
StephanEwen
committedSep 2, 2014
[FLINK-1020] Introduce minBy and maxBy

tobwiens
authored and
StephanEwen
committedSep 2, 2014

Commits on Sep 1, 2014

Some simplifications to the PiEstimation example
StephanEwen
committedSep 1, 2014
Add Pi approximation Java example

mariemayadi
authored and
StephanEwen
committedSep 1, 2014
[FLINK-1084] Fix broken links in "How to add an operator"
StephanEwen
committedSep 1, 2014
[FLINK-1078] PrintingOutputFormat uses same partition indexing as FileOutputFormat.
StephanEwen
committedSep 1, 2014
[FLINK-1079] Fix inconsistent parameter naming
StephanEwen
committedSep 1, 2014
[FLINK-1075] Removed the AsynchronousPartialSorter.

tillrohrmann
authored and
StephanEwen
committedSep 1, 2014
[FLINK-1070] Change return type of "getBroadcastVariable()" to List.
StephanEwen
committedSep 1, 2014

Commits on Aug 29, 2014

[streaming] Add redis dependency notices to binary distribution NOTICE file and DEPENDENCIES file
StephanEwen
committedAug 29, 2014
[streaming] Added customizable timestamps to window operations

ghermann
authored and
StephanEwen
committedAug 29, 2014
[streaming] Added exceptions for wrong usage of StreamExecutionEnvironment

ghermann
authored and
StephanEwen
committedAug 29, 2014
[streaming] GroupReduceInvokable update

szape
authored and
StephanEwen
committedAug 29, 2014
[streaming] StreamInvokable refactor and javadoc update + StreamRecordSerializer update

gyfora
authored and
StephanEwen
committedAug 29, 2014
[FLINK-1065] [streaming] Explicitly adding commons-math dependency

mbalassi
authored and
StephanEwen
committedAug 29, 2014
[streaming] Removed assembly execution on maven package for connectors

mbalassi
authored and
StephanEwen
committedAug 29, 2014
[streaming] Tests added for Reduce, GroupReduce and BatchGroupReduce invokables

gyfora
authored and
StephanEwen
committedAug 29, 2014
[streaming] Added MockCoInvokable, replaced environments with it in CoFunction tests

ghermann
authored and
StephanEwen
committedAug 29, 2014
[streaming] Mutable and Immutable invoke in CoInvokable

jfeher
authored and
StephanEwen
committedAug 29, 2014