This repository has been archived by the owner on May 17, 2021. It is now read-only.

Commits

Commits on Dec 11, 2014

[FLINK-1310] Change ClosureCleaner Logging to DEBUG

aljoscha
authored and
uce
committed
[scala] Add withParameters() support for sinks/sources

aljoscha
authored and
uce
committed

Commits on Dec 10, 2014

Fixed java quickstart example

cebe
authored and
rmetzger
committed
[FLINK-1040] Updated JavaDocs and removed deprecated types() calls from examples and tests
fhueske
committed
[FLINK-1040] Make types() call in projections optional

dukechain
authored and
fhueske
committed
[java8] Fix pom.xml to properly work with Eclipse m2e
StephanEwen
committed
[FLINK-1316] [web client] Fix plan display for nodes referenced from multiple closures.
StephanEwen
committed
[FLINK-1315] [optimizer] Fix bug in branch tracking logic.
StephanEwen
committed
[FLINK-1315] [optimizer] Extra test reproducing the IllegalStateException bug in bulk iterations.
StephanEwen
committed
Updated java 8 package to match flink-examples standards
mbalassi
committed
[streaming] Java 8 WordCount example added for streaming
mbalassi
committed
[FLINK-1312] [streaming] OutputSelector changed to SAM-type to allow java 8 lambdas for splitting

gyfora
authored and
mbalassi
committed
[FLINK-1161] [streaming] Streaming API type handling rework to support java 8 lambdas

gyfora
authored and
mbalassi
committed

Commits on Dec 9, 2014

[FLINK-1311] [optimizer] Correctly tag static/dynamic path for auxiliary nodes in iterations.
StephanEwen
committed

Commits on Dec 8, 2014

Commits on Dec 5, 2014