Commits

History for

Commits on Dec 18, 2014

Updated all JobManager and TaskManager relevant test cases to work with actors.
tillrohrmann
committedDec 18, 2014
Removed old RPC service.
tillrohrmann
committedDec 18, 2014
Reworked the EventCollector and the ArchiveListener as actors.
tillrohrmann
committedDec 18, 2014

Commits on Dec 16, 2014

Bump version to 0.9-incubating-SNAPSHOT
StephanEwen
committedDec 16, 2014

Commits on Dec 14, 2014

[misc] Fix/suppress various compiler warnings.
StephanEwen
committedDec 14, 2014

Commits on Dec 10, 2014

Commits on Dec 9, 2014

[FLINK-1311] [optimizer] Correctly tag static/dynamic path for auxiliary nodes in iterations.
StephanEwen
committedDec 9, 2014

Commits on Dec 1, 2014

[FLINK-984] Compiler tests for distinct(). Adopted the old code from @markus-h
rmetzger
committedDec 1, 2014

Commits on Nov 27, 2014

[FLINK-1290] Fix Optimizer to create plans when encountering incompatible partitionings.
StephanEwen
committedNov 27, 2014

Commits on Nov 26, 2014

Commits on Nov 25, 2014

[FLINK-1249] [APIs] [compiler] Add custom partitioner for CoGroup

StephanEwen
authored and
tillrohrmann
committedNov 25, 2014

Commits on Nov 21, 2014

[FLINK-1263] [optimizer] Implement compatibility checks for binary operators and custom partitioning
StephanEwen
committedNov 21, 2014

Commits on Nov 20, 2014

[FLINK-820] [compiler] Support for disconnected data flows
StephanEwen
committedNov 20, 2014
[FLINK-1264] [compiler] Properly forward custom partitioners to the runtime
StephanEwen
committedNov 20, 2014

Commits on Nov 19, 2014

[FLINK-1254] [compiler] Fix compiler bug for pipeline breaker placement
StephanEwen
committedNov 19, 2014

Commits on Nov 18, 2014

[FLINK-1209] [compiler] Improve error messages when forgetting to close an iteration
StephanEwen
committedNov 18, 2014
[FLINK-1237] Add support for custom partitioners
StephanEwen
committedNov 18, 2014

Commits on Nov 12, 2014

[FLINK-1235] Compiler accepts iterations referenced from the static path of other iterations
StephanEwen
committedNov 12, 2014

Commits on Nov 5, 2014

[FLINK-1214] Prevent partitionings on subsets of fields from being pushed down
StephanEwen
committedNov 5, 2014

Commits on Nov 4, 2014

Commits on Nov 3, 2014

Implement coarse-grained fault tolerance
StephanEwen
committedNov 3, 2014

Commits on Oct 26, 2014

Set version to 0.8-incubating-SNAPSHOT
rmetzger
committedOct 26, 2014

Commits on Oct 18, 2014

[FLINK-1167] Handle unions at the root of the iteration

StephanEwen
authored and
rmetzger
committedOct 18, 2014
[FLINK-1164] Gracefully handle empty (identity) iterations

StephanEwen
authored and
rmetzger
committedOct 18, 2014

Commits on Oct 14, 2014

Commits on Oct 9, 2014

[FLINK-1150] Fix size estimate for FilterNode. Data size changes proportional to cardinality.
fhueske
committedOct 9, 2014

Commits on Oct 8, 2014

[FLINK-1032] Rework support for POJO types in the Java API
rmetzger
committedOct 8, 2014