Commits

History for

Commits on Nov 18, 2015

[FLINK-2233] Update InputF nextRecord javadocs
zentol
committedNov 18, 2015

Commits on Nov 3, 2015

[FLINK-2958] Remove hard coded number of execution retries

uce
authored and
mxm
committedNov 3, 2015
[FLINK-2930] Respect ExecutionConfig execution retry delay

uce
authored and
mxm
committedNov 3, 2015

Commits on Oct 29, 2015

[FLINK-2559] Clean up JavaDocs

hczerpak
authored and
fhueske
committedOct 29, 2015

Commits on Oct 26, 2015

[FLINK-2890] Port StringSerializationSpeedBenchmark to JMH.

gallenvara
authored and
fhueske
committedOct 26, 2015

Commits on Oct 23, 2015

[FLINK-2893] [runtime] Consistent naming of recovery config parameters

uce
authored and
fhueske
committedOct 23, 2015
[release] update version to 1.0-SNAPSHOT
mxm
committedOct 23, 2015

Commits on Oct 21, 2015

[FLINK-2876] Minutiae

greghogan
authored and
fhueske
committedOct 21, 2015
[FLINK-2743] Add XORShfitRandom and use it in RandomSamplers.

chengxiang li
authored and
fhueske
committedOct 21, 2015

Commits on Oct 20, 2015

[FLINK-2864] Make State of General-Purpose Window Operators Fault-Tolerant
aljoscha
committedOct 20, 2015
[FLINK-2873] detect & serve the job manager log files correctly
mxm
committedOct 20, 2015

Commits on Oct 19, 2015

[FLINK-2354] [runtime] Add job graph and checkpoint recovery

uce
authored and
tillrohrmann
committedOct 19, 2015
[FLINK-2842] [documentation] Remove Flink S3FileSystem, extend documentation to use Hadoop S3FileSystem.
fhueske
committedOct 19, 2015

Commits on Oct 17, 2015

[FLINK-2844] [web frontend] Remove old web interface

mxm
authored and
StephanEwen
committedOct 17, 2015

Commits on Oct 16, 2015

Commits on Oct 9, 2015

[FLINK-2784] Remove deprecated configuration keys and updated documentation

fhueske
authored and
vasia
committedOct 9, 2015
[FLINK-2818] [docs] Correct javadocs of *ReduceDriver classes and some methods in the API.

ggevay
authored and
chiwanpark
committedOct 9, 2015
[FLINK-2576] [javaAPI] [scalaAPI] [optimizer] Add outerJoin to DataSet API (Java, Scala) and optimizer.

jkovacs
authored and
fhueske
committedOct 9, 2015
[FLINK-2576] Add outer join base operator.

r-pogalz
authored and
fhueske
committedOct 9, 2015

Commits on Oct 8, 2015

[FLINK-1789][core][runtime] Allow adding of URLs to the usercode class loader

twalthr
authored and
mxm
committedOct 8, 2015
[FLINK-2790] [yarn] [ha] Add high availability support for Yarn

tillrohrmann
authored and
uce
committedOct 8, 2015

Commits on Oct 7, 2015

[FLINK-2066][core] Add configuration of delay between execution retries at job level

WangCHX
authored and
fhueske
committedOct 7, 2015

Commits on Oct 6, 2015

Commits on Oct 2, 2015

[FLINK-1599][docs] TypeComperator with no keys and comparators matches some elements
mxm
committedOct 2, 2015
[FLINK-2525] Add configuration support in Storm-compatibility

ffbin
authored and
mjsax
committedOct 2, 2015

Commits on Oct 1, 2015

[FLINK-2783] Remove "degreeOfParallelism" API calls

supermegaciaccount
authored and
StephanEwen
committedOct 1, 2015
[FLINK-2766] [core] Add proper handling of IPv6 address literals in URLs
StephanEwen
committedOct 1, 2015
[FLINK-2781] [core] Cleanup NetUtils.
StephanEwen
committedOct 1, 2015

Commits on Sep 29, 2015

[FLINK-2775] [CLEANUP] Cleanup code as part of theme to be more consistent on Utils classes
hsaputra
committedSep 29, 2015
[FLINK-2723] [core] CopyableValue method to copy into new instance

greghogan
authored and
StephanEwen
committedSep 29, 2015