Commits

History for

Commits on Jan 12, 2016

[Docs] Fixed code example in streaming docs
mjsax
committedJan 12, 2016

Commits on Jan 11, 2016

[FLINK-2976] [runtime, tests] Add SavepointCoordinator
uce
committedJan 11, 2016
[FLINK-2976] [docs] Add docs about savepoints
uce
committedJan 11, 2016

Commits on Jan 7, 2016

[docs] Add "Iterator Data Sink" section to DataStream guide.

Filipe Correia
authored and
fhueske
committedJan 7, 2016
[FLINK-3176] Improve documentation for window apply

rtudoran
authored and
fhueske
committedJan 7, 2016

Commits on Jan 4, 2016

[FLINK-3186] [core] Deprecate DataSink.sortLocalOutput() methods

smarthi
authored and
StephanEwen
committedJan 4, 2016

Commits on Dec 21, 2015

[FLINK-7] Add range partitioning with automatic sampling of key distribution

chengxiang li
authored and
fhueske
committedDec 21, 2015

Commits on Dec 9, 2015

Commits on Dec 6, 2015

[hotfix] Minor JobManager doc fix

jaoki
authored and
StephanEwen
committedDec 6, 2015
[docs] Fix TumblingTimeWindows.of(AbstractTime) examples
uce
committedDec 6, 2015
[docs] Add import statements to DataStream example programs (Java/Scala)
uce
committedDec 6, 2015

Commits on Dec 5, 2015

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

Commits on Dec 2, 2015

[FLINK-3080] Relax restrictions of DataStream.union()
aljoscha
committedDec 2, 2015
[FLINK-2115] [Table API] support no aggregation after groupBy.

chengxiang li
authored and
aljoscha
committedDec 2, 2015
[FLINK-2837][storm] various improvements for the compatibility layer
mxm
committedDec 2, 2015

Commits on Dec 1, 2015

[FLINK-2624] improvements to the RabbitMQ source
mxm
committedDec 1, 2015
[FLINK-3092] [docs] Fix Scala API quick start word count example

phatak-dev
authored and
chiwanpark
committedDec 1, 2015

Commits on Nov 30, 2015

[FLINK-2950] [ml] [docs] Fix markdown rendering problem in SVM documentation

chiwanpark
authored and
StephanEwen
committedNov 30, 2015
[FLINK-3083] [docs] Add docs on how to configure streaming fault tolerance.
StephanEwen
committedNov 30, 2015

Commits on Nov 29, 2015

[FLINK-2961] [table] Add support for basic type Date in Table API
twalthr
committedNov 29, 2015

Commits on Nov 27, 2015

[FLINK-3054] Remove R (return) type variable from SerializationSchema
rmetzger
committedNov 27, 2015

Commits on Nov 25, 2015

[docs][hotfix] Fix wrong window definitions in the docs

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

zentol
authored and
fhueske
committedNov 25, 2015
[docs][streaming] fix code examples which use 'implements'
mxm
committedNov 25, 2015

Commits on Nov 24, 2015

[FLINK-2996] Introduce configuration parameter for BlobServer port
rmetzger
committedNov 24, 2015
[docs, setup] Add missing parenthesis
uce
committedNov 24, 2015
[docs, setup] Add note about (task|job)manager scripts
uce
committedNov 24, 2015

Commits on Nov 21, 2015

[hotfix][docs] Fix default config value, highlight detail in config
rmetzger
committedNov 21, 2015

Commits on Nov 20, 2015

[FLINK-3009] Add dockerized jekyll environment

jaoki
authored and
hsaputra
committedNov 20, 2015
[FLINK-2860] [ml] [docs] Remove an undefined argument in FlinkML documentation

chiwanpark
authored and
tillrohrmann
committedNov 20, 2015
[doc] Fix Documentation formatting for recently added ExecutionEnvironment.readSequenceFile()

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