Commits

Commits on Jan 18, 2015

Commits on Jan 16, 2015

[runtime tests] Fixes TaskManagerTest.testRunJobWithForwardChannel which caused spurious errors. Doubles the timeout for tests.
tillrohrmann
committedJan 16, 2015
[FLINK-1183] Generate gentle notification message when Flink is started with Java 6

Ajay Bhat
authored and
uce
committedJan 16, 2015

Commits on Jan 15, 2015

[FLINK-1112] Additional checks for KeySelector group sorting and minor fixes
fhueske
committedJan 15, 2015
[FLINK-1112] Add KeySelector group sorting on KeySelector grouping

qmlmoon
authored and
fhueske
committedJan 15, 2015
[FLINK-1271] [hadoop] Remove Writable limitation from Hadoop format and function wrappers

FelixNeutatz
authored and
fhueske
committedJan 15, 2015
[hotfix] Also use java closure cleaner on grouped operations
aljoscha
committedJan 15, 2015
[FLINK-1405] [windows] Fix Windows scripts (flink.bat and start-local.bat)
fhueske
committedJan 15, 2015
Remove dup code fromRemoteExecutor#executePlan method
hsaputra
committedJan 15, 2015

Commits on Jan 14, 2015

[FLINK-1397] Fix logfile access from JobManager web interface
rmetzger
committedJan 14, 2015

Commits on Jan 13, 2015

[scala] Disable Warning Message in TypeAnalyzer
aljoscha
committedJan 13, 2015

Commits on Jan 12, 2015

Undo erroneous commit 86f8753
rmetzger
committedJan 12, 2015
[FLINK-1380] [streaming] Updated SplitDataStream to extend DataStream to get rid of selectAll method for splits

gyfora
authored and
mbalassi
committedJan 12, 2015
[FLINK-986] [FLINK-25] [Distributed runtime] Add initial support for intermediate results
uce
committedJan 12, 2015

Commits on Jan 11, 2015

[FLINK-1378] [scala] Add support for Try[A] (Success/Failure)

aljoscha
authored and
StephanEwen
committedJan 11, 2015
[FLINK-1378] Add support for Throwables in KryoSerializer

aljoscha
authored and
StephanEwen
committedJan 11, 2015
[FLINK-1378] [scala] Fix type extraction for nested type parameters

aljoscha
authored and
StephanEwen
committedJan 11, 2015
[FLINK-1386] [quickstart] Fix pom in java quickstart archetype
StephanEwen
committedJan 11, 2015
[FLINK-1358] [streaming] Streaming added to the quickstarts

mbalassi
authored and
StephanEwen
committedJan 11, 2015
[FLINK-1225] Fix for quickstart packaging

mbalassi
authored and
StephanEwen
committedJan 11, 2015

Commits on Jan 9, 2015

[FLINK-1197] [docs] Add information about types and type extraction
StephanEwen
committedJan 9, 2015
Fix typo in README.md
uce
committedJan 9, 2015

Commits on Jan 8, 2015