Commits

History for

Commits on Mar 26, 2015

[FLINK-1755] Fix possible NullPointerException in LocalInputChannel
uce
committedMar 26, 2015

Commits on Mar 25, 2015

[FLINK-1512] [tests] Add integration tests for CsvReader

chiwanpark
authored and
fhueske
committedMar 25, 2015
[FLINK-1512] [scala api] Add CsvReader for reading into POJOs

chiwanpark
authored and
fhueske
committedMar 25, 2015
[FLINK-1512] [java api] Add CsvReader for reading into POJOs

chiwanpark
authored and
fhueske
committedMar 25, 2015
[Flink-1780] Rename FlatCombineFunction to GroupCombineFunction

smarthi
authored and
mxm
committedMar 25, 2015

Commits on Mar 23, 2015

[FLINK-1679] use a consistent name for parallelism
mxm
committedMar 23, 2015

Commits on Mar 22, 2015

[FLINK-1763] [streaming] Remove cancel from SinkFunction

gyfora
authored and
mbalassi
committedMar 22, 2015

Commits on Mar 21, 2015

[streaming] Add test that runs streaming with fault tolerance
StephanEwen
committedMar 21, 2015

Commits on Mar 20, 2015

[FLINK-1760] [maven] Added Scala version profiles to support building with Scala 2.11

aalexandrov
authored and
StephanEwen
committedMar 20, 2015
test refactoring fix

senorcarbone
authored and
gyfora
committedMar 20, 2015
[optimizer] Rename optimizer project to "flink-optimizer" (previously flink-compiler)
StephanEwen
committedMar 20, 2015
[FLINK-441] [optimizer] Rename Pact* and Nephele* classes
StephanEwen
committedMar 20, 2015
[FLINK-441] [optimizer] Rename "o.a.flink.compiler" to "o.a.flink.optimizer"
StephanEwen
committedMar 20, 2015

Commits on Mar 18, 2015

Commits on Mar 17, 2015

[FLINK-1671] [tests] Rename "ExecutionMode" in MultiProgramTestBase to "TestExecutionMode"
StephanEwen
committedMar 17, 2015

Commits on Mar 15, 2015

[FLINK-1691] [tests] Fix and cleanup CountCollectITCase
StephanEwen
committedMar 15, 2015

Commits on Mar 13, 2015

[tests] Increase timeout for ProcessFailureBatchRecoveryITCase to compensate for slow Travis runs
StephanEwen
committedMar 13, 2015

Commits on Mar 11, 2015

[FLINK-1605] Bundle all hadoop dependencies and shade guava away
rmetzger
committedMar 11, 2015

Commits on Mar 9, 2015

[FLINK-1668] [core] Add a config option to specify delays between restarts
StephanEwen
committedMar 9, 2015
[FLINK-1667] [runtime] Add test for recovery after TaskManager process failure
StephanEwen
committedMar 9, 2015
[tests] Add comments and to recovery tests
StephanEwen
committedMar 9, 2015

Commits on Mar 5, 2015

Commits on Mar 4, 2015

Commits on Mar 3, 2015

[FLINK-1555] Add serializer hierarchy debug util
rmetzger
committedMar 3, 2015

Commits on Feb 27, 2015

[java-api][scala-api] convenience methods count/collect to transfer a DataSet to the client
mxm
committedFeb 27, 2015

Commits on Feb 25, 2015

[FLINK-1607] [tests] Fixes SimpleRecoveryITCase by rebalancing the data sources so that all mappers receive at least one element

tillrohrmann
authored and
uce
committedFeb 25, 2015
[FLINK-1606] [tests] Fixes JobManagerFailsITCase for Akka 2.2.1 by setting gate-invalid-address-for = 5s and quarantine-systems-for = off

tillrohrmann
authored and
uce
committedFeb 25, 2015

Commits on Feb 24, 2015

[jobmanager] Add a process reaper to kill the JobManager process when the main actor dies.
StephanEwen
committedFeb 24, 2015