Commits

Branch selector

 master

User selector

rmetzger

Datepicker

All time

Commit History

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

Commits on Apr 5, 2016

• [FLINK-3283] Improve Kafka test stability

  rmetzger

  committed
  02a3dfd

  Copy full SHA for 02a3dfd

Commits on Apr 4, 2016

• [hotfix][examples] Remove System.exit() from Kafka example

  rmetzger

  committed
  93d9384

  Copy full SHA for 93d9384

Commits on Mar 24, 2016

• [FLINK-3658][Kafka] Allow producing into multiple topics

  Show description for c77e5ec
  rmetzger

  committed
  c77e5ec

  Copy full SHA for c77e5ec

Commits on Mar 21, 2016

• [hotfix][Kafka 0.9] Avoid committing offsets to closed consumer

  rmetzger

  committed
  35892ed

  Copy full SHA for 35892ed

Commits on Mar 16, 2016

• [FLINK-1964] Reimplement TwitterSource

  Show description for e70d49e
  rmetzger

  committed
  e70d49e

  Copy full SHA for e70d49e

Commits on Mar 4, 2016

• [hotfix] Make 'force-shading' deployable

  rmetzger

  committed
  dbe9e59

  Copy full SHA for dbe9e59

Commits on Feb 29, 2016

• [FLINK-3540] Shade org.htrace in flink-shaded-hadoop to get rid of its Guava dependency

  Show description for 51fc298
  rmetzger

  committed
  51fc298

  Copy full SHA for 51fc298

• Bump version to 1.1-SNAPSHOT

  rmetzger

  committed
  512c84f

  Copy full SHA for 512c84f

Commits on Feb 26, 2016

• [hotfix][deploy script] Deploy 'release-*' branches as well

  rmetzger

  committed
  2d64ca2

  Copy full SHA for 2d64ca2

• [FLINK-3509] Update Hadoop minor versions to latest & sync travis and release scripts

  Show description for 9692c83
  rmetzger

  committed
  9692c83

  Copy full SHA for 9692c83

Commits on Feb 25, 2016

• [hotfix][build scripts] Ensure that the hadoop1 version is set properly everywhere

  rmetzger

  committed
  56e660d

  Copy full SHA for 56e660d

Commits on Feb 23, 2016

• [hotfix][release script] make sure the quickstart depends on scala 2.10

  rmetzger

  committed
  271a715

  Copy full SHA for 271a715

• [FLINK-3440][Kafka 0.8] Commit also offsets retrieved from Kafka into the OffsetStore (ZK)

  Show description for 8626971
  rmetzger

  committed
  8626971

  Copy full SHA for 8626971

Commits on Feb 22, 2016

• [FLINK-3455] Bump Kafka to 0.9.0.1 and 0.8.2.2

  Show description for 8656ed5
  rmetzger

  committed
  8656ed5

  Copy full SHA for 8656ed5

Commits on Feb 19, 2016

• [FLINK-3386][FLINK-3368][Kafka 0.8] Cleanup Kafka Connector

  Show description for 8912fb0
  rmetzger

  committed
  8912fb0

  Copy full SHA for 8912fb0

• [FLINK-3386] Ensure Flink Kafka 0.8 is correctly using 'auto.offset.reset'

  rmetzger

  committed
  3a8717f

  Copy full SHA for 3a8717f

• [FLINK-3368][Kafka 0.8] Handle leader changes in Kafka Consumer.

  rmetzger

  committed
  d48bb59

  Copy full SHA for d48bb59

Commits on Feb 16, 2016

• [FLINK-3296] Remove 'flushing' behavior of the OutputFormat support of the DataStream API

  Show description for 2714aaf
  rmetzger

  committed
  2714aaf

  Copy full SHA for 2714aaf

Commits on Feb 15, 2016

• [FLINK-3158] Enforce maven version to be < 3.3 when building a release

  rmetzger

  committed
  65d0805

  Copy full SHA for 65d0805

Commits on Feb 12, 2016

• [FLINK-3270] Add Kafka example

  Show description for b6bfcf0
  rmetzger

  committed
  b6bfcf0

  Copy full SHA for b6bfcf0

Commits on Feb 10, 2016

• [FLINK-3341] Make 'auto.offset.reset' compatible with Kafka 0.8 and 0.9

  Show description for 9173825
  

  rmetzger

  authored and

  StephanEwen

  committed
  9173825

  Copy full SHA for 9173825

Commits on Feb 9, 2016

• [build system] Skip javadoc generation for java8 and snapshot deployments

  rmetzger

  committed
  59b237b

  Copy full SHA for 59b237b

• [FLINK-3286] Remove the files from the debian packaging as well

  rmetzger

  committed
  a4f0692

  Copy full SHA for a4f0692

Commits on Feb 8, 2016

• [hotfix][doc] Add note on how to use custom loggers with a per-job-yarn cluster

  rmetzger

  committed
  22423e2

  Copy full SHA for 22423e2

Commits on Feb 5, 2016

• [FLINK-3093] Introduce annotations for interface stability in remaining modules

  Show description for b54499b
  rmetzger

  committed
  b54499b

  Copy full SHA for b54499b

Commits on Feb 4, 2016

• [FLINK-3328] Incorrectly shaded dependencies in flink-runtime

  Show description for 7378f01
  rmetzger

  committed
  7378f01

  Copy full SHA for 7378f01

Commits on Feb 2, 2016

• [FLINK-3247] Remove * exclude from quickstarts

  Show description for 360f02b
  rmetzger

  committed
  360f02b

  Copy full SHA for 360f02b

• [FLINK-3287] Shade Curator dependency into flink-connector-kafka-0.8

  rmetzger

  committed
  cb1a5ec

  Copy full SHA for cb1a5ec

Pagination

Previous

Next