Commits

Branch selector

 master

User selector

rmetzger

Datepicker

All time

Commit History

Commits on Aug 11, 2016

• [hotfix][docs] Fix RMQ Sink code example

  rmetzger

  committed
  e9b8657

  Copy full SHA for e9b8657

Commits on Aug 9, 2016

• [build] disable travis cache

  rmetzger

  committed
  5133c89

  Copy full SHA for 5133c89

• [hotfix][build] Fix release script

  rmetzger

  committed
  50cf131

  Copy full SHA for 50cf131

Commits on Aug 8, 2016

• [hotfix][kinesis] Fix build instructions

  rmetzger

  committed
  6a88377

  Copy full SHA for 6a88377

Commits on Jul 15, 2016

• [FLINK-4186] Use Flink metrics to report Kafka metrics

  Show description for 41f5818
  rmetzger

  committed
  41f5818

  Copy full SHA for 41f5818

• [FLINK-4142][docs] Add warning about YARN HA bug

  Show description for d08b189
  

  rmetzger

  authored and

  zentol

  committed
  d08b189

  Copy full SHA for d08b189

Commits on Jul 13, 2016

• [FLINK-4127] Check API compatbility for 1.1 in flink-core

  Show description for 6b7bb76
  rmetzger

  committed
  6b7bb76

  Copy full SHA for 6b7bb76

Commits on Jul 12, 2016

• [hotfix][docs] Add note about Kinesis producer limitations

  Show description for 971dcc5
  rmetzger

  committed
  971dcc5

  Copy full SHA for 971dcc5

• [FLINK-4191] Expose shard information in kinesis deserialization schema

  Show description for 662b458
  rmetzger

  committed
  662b458

  Copy full SHA for 662b458

Commits on Jul 11, 2016

• [FLINK-4157] Catch Kafka metrics serialization exceptions

  Show description for 36aad48
  rmetzger

  committed
  36aad48

  Copy full SHA for 36aad48

Commits on Jul 6, 2016

• [FLINK-4137] Tell Akka to shut down the JVM on fatal errors

  Show description for cdd5e4c
  rmetzger

  committed
  cdd5e4c

  Copy full SHA for cdd5e4c

• [FLINK-4151] Split test execution on travis into two groups

  Show description for f149938
  rmetzger

  committed
  f149938

  Copy full SHA for f149938

Commits on Jul 5, 2016

• [FLINK-4146] Fix YARN test failure

  Show description for 424c082
  rmetzger

  committed
  424c082

  Copy full SHA for 424c082

• [FLINK-3995] [build] Fix failing tests and add missing dependencies

  Show description for 8a2c03e
  rmetzger

  committed
  8a2c03e

  Copy full SHA for 8a2c03e

Commits on Jul 4, 2016

• [hotfix] Fix NPE in NetworkStackThroughputITCase

  rmetzger

  committed
  7ee0425

  Copy full SHA for 7ee0425

• [FLINK-4027] Flush FlinkKafkaProducer on checkpoints

  Show description for 7206b0e
  rmetzger

  committed
  7206b0e

  Copy full SHA for 7206b0e

Commits on Jun 29, 2016

• [FLINK-4085][Kinesis] Set Flink-specific user agent

  Show description for 123be22
  rmetzger

  committed
  123be22

  Copy full SHA for 123be22

Commits on Jun 28, 2016

• [FLINK-4099] Fix CliFrontendYarnAddressConfigurationTest failures

  Show description for 76ba2d1
  rmetzger

  committed
  76ba2d1

  Copy full SHA for 76ba2d1

Commits on Jun 27, 2016

• [hotfix][docs] Add warning to Cassandra documentation

  

  rmetzger

  authored and

  zentol

  committed
  6744b85

  Copy full SHA for 6744b85

Commits on Jun 9, 2016

• [FLINK-3530] Fix Kafka08 instability: Avoid restarts from SuccessException

  Show description for ccc86e9
  rmetzger

  committed
  ccc86e9

  Copy full SHA for ccc86e9

• [FLINK-3763] Some RMQ cleanups

  Show description for 6cc1c17
  rmetzger

  committed
  6cc1c17

  Copy full SHA for 6cc1c17

• [hotfix] Improve ParameterTool exception

  Show description for b5e2e36
  rmetzger

  committed
  b5e2e36

  Copy full SHA for b5e2e36

• [hotfix] Fix JSONDeserializationSchema for Kafka

  rmetzger

  committed
  042ad7b

  Copy full SHA for 042ad7b

Commits on Jun 8, 2016

• [FLINK-4011] Keep UserCodeClassLoader in archived ExecutionGraphs

  Show description for 65ee28c
  rmetzger

  committed
  65ee28c

  Copy full SHA for 65ee28c

Commits on May 27, 2016

• [FLINK-3923] Minor cleanups and enhancements

  Show description for 23d1cba
  rmetzger

  committed
  23d1cba

  Copy full SHA for 23d1cba

• [FLINK-3129] Fix ES2 issue

  rmetzger

  committed
  08eca76

  Copy full SHA for 08eca76

• [FLINK-3129] Fix breaking changes in flink-core

  rmetzger

  committed
  b0acd97

  Copy full SHA for b0acd97

• [FLINK-3129] Bring infrastructure for ensuring interface stability in place

  Show description for 6c07936
  rmetzger

  committed
  6c07936

  Copy full SHA for 6c07936

Commits on May 18, 2016

• [FLINK-3229] Shade Google Protobuf into Kinesis connector to avoid runtime version conflict

  rmetzger

  committed
  fd3dba6

  Copy full SHA for fd3dba6

Commits on May 5, 2016

• [docs] Document difference between 'stop' and 'cancel'

  rmetzger

  committed
  e97f4e6

  Copy full SHA for e97f4e6

Commits on Apr 28, 2016

• [FLINK-3428] Minor fixes

  rmetzger

  committed
  c81151e

  Copy full SHA for c81151e

Commits on Apr 26, 2016

• [FLINK-3804][docs] Fix YARN and Kafka docs

  rmetzger

  committed
  e293e68

  Copy full SHA for e293e68

Commits on Apr 20, 2016

• [FLINK-3230] Add producer for Amazon Kinesis Streams into Flink

  Show description for 409c346
  rmetzger

  committed
  409c346

  Copy full SHA for 409c346

Commits on Apr 11, 2016

• [FLINK-3712] Make all dynamic properties available to the CLI frontend

  Show description for b368cb2
  rmetzger

  committed
  b368cb2

  Copy full SHA for b368cb2

Commits on Apr 7, 2016

• [FLINK-3697] Properly access type information for nested POJO key selection

  Show description for 9f52422
  rmetzger

  committed
  9f52422

  Copy full SHA for 9f52422

Pagination

Previous

Next