Commits

Commits on Oct 15, 2015

[FLINK-2856] Introduce flink.version property into quickstart archetype
rmetzger
committedOct 15, 2015

Commits on Oct 5, 2015

[hotfix] Execute YARN integration tests only upon request (by activating the 'include-yarn-tests' profile)
rmetzger
committedOct 5, 2015

Commits on Sep 30, 2015

[FLINK-2703] Prepare Flink for being used with Logback.
rmetzger
committedSep 30, 2015

Commits on Sep 24, 2015

[FLINK-2200] [build system] Deploy Flink 2.11 with every build (nightly)
rmetzger
committedSep 24, 2015

Commits on Sep 22, 2015

Commits on Sep 21, 2015

[build system] Update secret keys for travis log delivery
rmetzger
committedSep 21, 2015
[FLINK2392] Increase memory for TaskManager
rmetzger
committedSep 21, 2015

Commits on Sep 11, 2015

[FLINK-2656] Fix behavior of FlinkKafkaConsumer for out of range offsets
rmetzger
committedSep 11, 2015

Commits on Sep 10, 2015

[FLINK-2639] Add repository for hdp specific jetty to 'vendor-repos'

rmetzger
authored and
fhueske
committedSep 10, 2015
[FLINK-2408] Define all maven properties outside build profiles
rmetzger
committedSep 10, 2015

Commits on Sep 9, 2015

[FLINK-2392] Improve YARN test stability
rmetzger
committedSep 9, 2015

Commits on Sep 7, 2015

[FLINK-2372] Add new FlinkKafkaProducer bases on the new producer API

rmetzger
authored and
StephanEwen
committedSep 7, 2015

Commits on Sep 2, 2015

[hotfix][docs] Update Kafka section in streaming guide to match the renamed class names
rmetzger
committedSep 2, 2015

Commits on Sep 1, 2015

[FLINK-2584] Check for unshaded classes in fat jar and shade curator

rmetzger
authored and
StephanEwen
committedSep 1, 2015

Commits on Aug 30, 2015

[FLINK-2543] [core] Fix user object deserialization for file-based state handles.

rmetzger
authored and
StephanEwen
committedAug 30, 2015
[hotfix] Include Hadoop version into EnvironmentInformation
rmetzger
committedAug 30, 2015

Commits on Aug 27, 2015

[FLINK-2326] [yarn] Write yarn properties file to temp directory

rmetzger
authored and
StephanEwen
committedAug 27, 2015
[FLINK-2386] [kafka connector] Remove copied Kafka code again. Implemented our own topic metadata retrieval.

rmetzger
authored and
StephanEwen
committedAug 27, 2015
[FLINK-2386] [kafka connector] Add new Kafka Consumer for Flink

rmetzger
authored and
StephanEwen
committedAug 27, 2015

Commits on Aug 26, 2015

[FLINK-2555] Properly pass security credentials in the Hadoop Input/Output format wrappers

rmetzger
authored and
uce
committedAug 26, 2015

Commits on Aug 5, 2015

[FLINK-1680] Remove Tachyon test and rename Maven module to "flink-fs-tests"

rmetzger
authored and
fhueske
committedAug 5, 2015

Commits on Jul 21, 2015

[docs] Document some missing configuration parameters

rmetzger
authored and
StephanEwen
committedJul 21, 2015

Commits on Jul 13, 2015

[FLINK-2008] [FLINK-2296] Fix checkpoint committing & KafkaITCase

rmetzger
authored and
StephanEwen
committedJul 13, 2015

Commits on Jul 8, 2015

[tools] Make release script a bit more flexible
rmetzger
committedJul 8, 2015

Commits on Jul 1, 2015

[FLINK-2158] Add support for null to the DateSerializer

rmetzger
authored and
StephanEwen
committedJul 1, 2015
[FLINK-2298] Add option to pass a custom name for Flink on YARN
rmetzger
committedJul 1, 2015

Commits on Jun 8, 2015

Add CONTRIBUTING.md file with pointers to our guides

rmetzger
authored and
mbalassi
committedJun 8, 2015

Commits on Jun 7, 2015

Commits on Jun 5, 2015

[FLINK-1565][FLINK-2078] Document ExecutionConfig and object reuse behavior
rmetzger
committedJun 5, 2015