Commits

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
[FLINK-3129] Fix breaking changes in flink-core
rmetzger
committedMay 27, 2016
[FLINK-3129] Bring infrastructure for ensuring interface stability in place
rmetzger
committedMay 27, 2016

Commits on May 18, 2016

[FLINK-3229] Shade Google Protobuf into Kinesis connector to avoid runtime version conflict
rmetzger
committedMay 18, 2016

Commits on May 5, 2016

[docs] Document difference between 'stop' and 'cancel'
rmetzger
committedMay 5, 2016

Commits on Apr 28, 2016

[FLINK-3428] Minor fixes
rmetzger
committedApr 28, 2016

Commits on Apr 26, 2016

[FLINK-3804][docs] Fix YARN and Kafka docs
rmetzger
committedApr 26, 2016

Commits on Apr 20, 2016

[FLINK-3230] Add producer for Amazon Kinesis Streams into Flink
rmetzger
committedApr 20, 2016

Commits on Apr 11, 2016

[FLINK-3712] Make all dynamic properties available to the CLI frontend
rmetzger
committedApr 11, 2016

Commits on Apr 7, 2016

[FLINK-3697] Properly access type information for nested POJO key selection
rmetzger
committedApr 7, 2016

Commits on Apr 5, 2016

[FLINK-3283] Improve Kafka test stability
rmetzger
committedApr 5, 2016