Commits

Commits on Nov 4, 2014

Commits on Nov 3, 2014

[FLINK-1198] Broadcast variables can share initialization via broadcast variable initializers
StephanEwen
committedNov 3, 2014
[FLINK-1198] Make Broadcast variables shared per taskmanager, rather than a shared singleton per JVM
StephanEwen
committedNov 3, 2014
[FLINK-1198] Broadcast variables are shared between tasks in the same TaskManager
StephanEwen
committedNov 3, 2014
[FLINK-1203] Use forked execution in all tests, except in the end-to-end integration tests in flink-tests
StephanEwen
committedNov 3, 2014
[FLINK-1205] Fix library cache manager to track references to tasks and revent accidental duplicate registration/deregistration
StephanEwen
committedNov 3, 2014
Make sure TaskManager does not accept task deployments when shutting down
StephanEwen
committedNov 3, 2014
Improve error messages in case of invalid file paths or URIs
StephanEwen
committedNov 3, 2014
Introduce a delay before restarts to make sure that taskmanager failures are detected before restart.
StephanEwen
committedNov 3, 2014
Implement coarse-grained fault tolerance
StephanEwen
committedNov 3, 2014
Remove obsolete collection execution example.
StephanEwen
committedNov 3, 2014
[FLINK-1202] Remove incomplete file outputs on failure
StephanEwen
committedNov 3, 2014
[FLINK-1203] Deactivate fork reuse in tests (workaround for potential surefire bug)
StephanEwen
committedNov 3, 2014

Commits on Oct 31, 2014

Another round to remove final modifier to private methods because it is not needed
hsaputra
committedOct 31, 2014

Commits on Oct 30, 2014

[docs] Various fixes in docs
StephanEwen
committedOct 30, 2014

Commits on Oct 29, 2014

Fix version and download paths in docs config
StephanEwen
committedOct 29, 2014

Commits on Oct 28, 2014

[FLINK-1181] Fix IOReadableWritable checks in RPC service
StephanEwen
committedOct 28, 2014
[FLINK-1182] Improve error messages for POJO type mismatches
StephanEwen
committedOct 28, 2014
Add DeltaPageRank example
StephanEwen
committedOct 28, 2014
[FLINK-1194] Fix Java quickstart archetype POM file
StephanEwen
committedOct 28, 2014

Commits on Oct 27, 2014

Remove unnecessary final modifier in PlanExecutor.loadExecutorClass method
hsaputra
committedOct 27, 2014
[FLINK-1178] Changed type preference to ValueType, WritableType, CaseClassType
tillrohrmann
committedOct 27, 2014
[FLINK-1187] [streaming] StreamingRuntimeContext added with API support for registering fault tolerant state objects for the operators

gyfora
authored and
mbalassi
committedOct 27, 2014
[FLINK-1185] [streaming] OperatorState and StateCheckpoint classes and implementations added for state checkpointing and rebalancing

gyfora
authored and
mbalassi
committedOct 27, 2014
[streaming] Removed obsolete state objects from streaming-core

gyfora
authored and
mbalassi
committedOct 27, 2014
[FLINK-1188] [streaming] Updated aggregations to work also on arrays by default

gyfora
authored and
mbalassi
committedOct 27, 2014
[FLINK-1175] [streaming] GroupBy updated to allow multiple field and keyselector groupings

gyfora
authored and
mbalassi
committedOct 27, 2014
[FLINK-1189] [streaming] Temporal cross refactor

gyfora
authored and
mbalassi
committedOct 27, 2014
[FLINK-1189] [streaming] Added cross operator

balidani
authored and
mbalassi
committedOct 27, 2014

Commits on Oct 26, 2014

Set version to 0.8-incubating-SNAPSHOT
rmetzger
committedOct 26, 2014
[build tools] update release sciprts
rmetzger
committedOct 26, 2014