Commits

Commits on Jan 28, 2016

[FLINK-3265] [rabbitmq] Fix concurrency bug in RabbitMQ

rmetzger
authored and
StephanEwen
committedJan 28, 2016

Commits on Jan 25, 2016

[FLINK-3280] Change Boolean.getBoolean to Boolean.valueOf

rmetzger
authored and
fhueske
committedJan 25, 2016
[FLINK-3274] Make accumulator names of Kafka connector unique

rmetzger
authored and
fhueske
committedJan 25, 2016

Commits on Jan 20, 2016

[FLINK-3058] Add support for Kafka 0.9.0.0
rmetzger
committedJan 20, 2016

Commits on Jan 19, 2016

[FLINK-3241] Fix Scala 2.11 build by moving some flink-table classes into the right directory
rmetzger
committedJan 19, 2016
[FLINK-3220] Remove javax.servlet exclusions from hadoop2 fat jar to fix Flink on HDP
rmetzger
committedJan 19, 2016
[FLINK-3241] Fix SNAPSHOT deployment for Scala 2.11
rmetzger
committedJan 19, 2016

Commits on Jan 14, 2016

[FLINK-1712] Remove "flink-staging" module
rmetzger
committedJan 14, 2016
[FLINK-3195] Rework quickstart example & some cleanups on the new examples
rmetzger
committedJan 14, 2016

Commits on Jan 7, 2016

[FLINK-3093] Introduce annotations for interface stability in flink-core
rmetzger
committedJan 7, 2016

Commits on Dec 30, 2015

[FLINK-3067] [kafka connector] Use curator for committing offsets to ZK from Kafka

rmetzger
authored and
StephanEwen
committedDec 30, 2015

Commits on Dec 10, 2015

[FLINK-3156] Fix NPE in KafkaConsumer when reading from SOME empty topics/partitions
rmetzger
committedDec 10, 2015

Commits on Dec 9, 2015

[FLINK-3074] Add config option to start YARN AM on port range
rmetzger
committedDec 9, 2015

Commits on Dec 8, 2015

[FLINK-3102] Allow reading from multiple topics with one FlinkKafkaConsumer instance
rmetzger
committedDec 8, 2015

Commits on Dec 7, 2015

[FLINK-2963] Forbid commons lang 3 SerializationUtils as well
rmetzger
committedDec 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-3061] Properly fail Kafka Consumer if broker is not available
rmetzger
committedNov 30, 2015

Commits on Nov 29, 2015

[FLINK-3081] Properly stop periodic Kafka committer
rmetzger
committedNov 29, 2015

Commits on Nov 28, 2015

[hotfix] Fix SimpleStringSchema serialization issue
rmetzger
committedNov 28, 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-3067] Enforce zkclient 0.7 for Kafka
rmetzger
committedNov 25, 2015
[hotfix] Register signal handler for JobManager and TaskManager
rmetzger
committedNov 25, 2015

Commits on Nov 24, 2015

[FLINK-2996] Introduce configuration parameter for BlobServer port
rmetzger
committedNov 24, 2015
[FLINK-3045] Properly expose the key of a Kafka message
rmetzger
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-2974] Add periodic offset committer for Kafka when checkpointing is disabled
rmetzger
committedNov 20, 2015

Commits on Nov 19, 2015

[FLINK-3032] Fix jackson-core dependency conflict with Hadoop 2.7.1.
rmetzger
committedNov 19, 2015

Commits on Nov 18, 2015

[hotfix][docs] Replace Count.of() with appropriate Count(Trigger|Evictor).of()
rmetzger
committedNov 18, 2015

Commits on Nov 17, 2015

[FLINK-2967] Increase timeout for LOCAL_HOST address detection strategy, give the local host address a higher priority

rmetzger
authored and
StephanEwen
committedNov 17, 2015

Commits on Nov 10, 2015

[FLINK-2992] Remove use of SerializationUtils
rmetzger
committedNov 10, 2015
[hotfix] Check for null in StreamSource.cancel()
rmetzger
committedNov 10, 2015

Commits on Nov 9, 2015

Commits on Nov 4, 2015

[FLINK-2898] Adopt deploy to maven script to new build order
rmetzger
committedNov 4, 2015