Commits

History for

Commits on Dec 30, 2015

[FLINK-3131] [core, runtime] Add checkpoint statistics tracker

uce
authored and
StephanEwen
committedDec 30, 2015

Commits on Dec 26, 2015

[hotfix] Trivial WriteMode comment fix

jaoki
authored and
StephanEwen
committedDec 26, 2015

Commits on Dec 21, 2015

[FLINK-2622] [streaming] Align Scala streaming writeAsCsv API call with Java API

tillrohrmann
authored and
fhueske
committedDec 21, 2015
[FLINK-3116] Remove RecordOperator

jaoki
authored and
fhueske
committedDec 21, 2015
[FLINK-7] Add range partitioning with automatic sampling of key distribution

chengxiang li
authored and
fhueske
committedDec 21, 2015

Commits on Dec 15, 2015

[FLINK-2882] [core] Improve performance of string conversions

greghogan
authored and
fhueske
committedDec 15, 2015

Commits on Dec 14, 2015

Commits on Dec 9, 2015

[FLINK-3074] Add config option to start YARN AM on port range
rmetzger
committedDec 9, 2015
[FLINK-3073] Replace Streaming Mode by Memory Allocation Mode
aljoscha
committedDec 9, 2015

Commits on Dec 7, 2015

Commits on Dec 5, 2015

[FLINK-2954] Add config parameter for passing environment variables to YARN
rmetzger
committedDec 5, 2015

Commits on Nov 30, 2015

[FLINK-2972] [JavaAPI] Remove Chill dependency from flink-java.
fhueske
committedNov 30, 2015
[FLINK-2351] [core] Remove IOFormat ConfigBuilders

zentol
authored and
StephanEwen
committedNov 30, 2015
[FLINK-3088] [serialization] Fix copy method of TypeSerializer which use Kryo
tillrohrmann
committedNov 30, 2015

Commits on Nov 26, 2015

[hotfix] Java-7-ify the ExecutionConfig class
StephanEwen
committedNov 26, 2015

Commits on Nov 25, 2015

[typo-fix] Fix typo in DelimitedInputFormat.java

fversaci
authored and
fhueske
committedNov 25, 2015
[FLINK-2906] Remove Record API

zentol
authored and
fhueske
committedNov 25, 2015

Commits on Nov 24, 2015

[FLINK-2996] Introduce configuration parameter for BlobServer port
rmetzger
committedNov 24, 2015
[FLINK-3064] [core] Add size check in GroupReduceOperatorBase

s1ck
authored and
tillrohrmann
committedNov 24, 2015

Commits on Nov 20, 2015

[FLINK-2974] Add periodic offset committer for Kafka when checkpointing is disabled
rmetzger
committedNov 20, 2015

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