Commits

Commits on Oct 21, 2016

[FLINK-4878][tests] Log test failure cause on INFO level
rmetzger
committedOct 21, 2016

Commits on Oct 14, 2016

[FLINK-3660][hotfix] Add missing default value in ConfigConstants
rmetzger
committedOct 14, 2016
[FLINK-3660] Measure latency and exposes them via a metric
rmetzger
committedOct 14, 2016

Commits on Oct 13, 2016

[hotfix][kafka] Backport Kafka09FetcherTest for Kafka010
rmetzger
committedOct 13, 2016

Commits on Oct 12, 2016

[hotfix][kafka] Undo DataGenerators changes (use inline kafka producer again
rmetzger
committedOct 12, 2016
[FLINK-3706] Fix YARN test instability
rmetzger
committedOct 12, 2016

Commits on Oct 11, 2016

[FLINK-4035] Refactor the Kafka 0.10 connector to be based upon the 0.9 connector
rmetzger
committedOct 11, 2016

Commits on Aug 29, 2016

[hotfix][quickstarts] Remove Jodatime exclusion
rmetzger
committedAug 29, 2016

Commits on Aug 25, 2016

[FLINK-3823] Fix travis log upload & upload logs to transfer.sh (14 days)
rmetzger
committedAug 25, 2016

Commits on Aug 11, 2016

[hotfix][docs] Fix RMQ Sink code example
rmetzger
committedAug 11, 2016

Commits on Aug 9, 2016

[build] disable travis cache
rmetzger
committedAug 9, 2016
[hotfix][build] Fix release script
rmetzger
committedAug 9, 2016

Commits on Aug 8, 2016

[hotfix][kinesis] Fix build instructions
rmetzger
committedAug 8, 2016

Commits on Jul 15, 2016

[FLINK-4186] Use Flink metrics to report Kafka metrics
rmetzger
committedJul 15, 2016
[FLINK-4142][docs] Add warning about YARN HA bug

rmetzger
authored and
zentol
committedJul 15, 2016

Commits on Jul 13, 2016

[FLINK-4127] Check API compatbility for 1.1 in flink-core
rmetzger
committedJul 13, 2016

Commits on Jul 12, 2016

[hotfix][docs] Add note about Kinesis producer limitations
rmetzger
committedJul 12, 2016
[FLINK-4191] Expose shard information in kinesis deserialization schema
rmetzger
committedJul 12, 2016

Commits on Jul 11, 2016

[FLINK-4157] Catch Kafka metrics serialization exceptions
rmetzger
committedJul 11, 2016

Commits on Jul 6, 2016

[FLINK-4137] Tell Akka to shut down the JVM on fatal errors
rmetzger
committedJul 6, 2016
[FLINK-4151] Split test execution on travis into two groups
rmetzger
committedJul 6, 2016

Commits on Jul 5, 2016

[FLINK-4146] Fix YARN test failure
rmetzger
committedJul 5, 2016
[FLINK-3995] [build] Fix failing tests and add missing dependencies
rmetzger
committedJul 5, 2016

Commits on Jul 4, 2016

[hotfix] Fix NPE in NetworkStackThroughputITCase
rmetzger
committedJul 4, 2016
[FLINK-4027] Flush FlinkKafkaProducer on checkpoints
rmetzger
committedJul 4, 2016

Commits on Jun 29, 2016

[FLINK-4085][Kinesis] Set Flink-specific user agent
rmetzger
committedJun 29, 2016

Commits on Jun 28, 2016

[FLINK-4099] Fix CliFrontendYarnAddressConfigurationTest failures
rmetzger
committedJun 28, 2016

Commits on Jun 27, 2016

[hotfix][docs] Add warning to Cassandra documentation

rmetzger
authored and
zentol
committedJun 27, 2016

Commits on Jun 9, 2016

[FLINK-3530] Fix Kafka08 instability: Avoid restarts from SuccessException
rmetzger
committedJun 9, 2016
[FLINK-3763] Some RMQ cleanups
rmetzger
committedJun 9, 2016
[hotfix] Improve ParameterTool exception
rmetzger
committedJun 9, 2016
[hotfix] Fix JSONDeserializationSchema for Kafka
rmetzger
committedJun 9, 2016

Commits on Jun 8, 2016

[FLINK-4011] Keep UserCodeClassLoader in archived ExecutionGraphs
rmetzger
committedJun 8, 2016

Commits on May 27, 2016

[FLINK-3923] Minor cleanups and enhancements
rmetzger
committedMay 27, 2016
[FLINK-3129] Fix ES2 issue
rmetzger
committedMay 27, 2016