Commits

Branch selector

 master

User selector

rmetzger

Datepicker

All time

Commit History

Commits on Jan 19, 2017

• [FLINK-5555] Document how to debug event time using watermarks (+ kafka metrics)

  Show description for b86a3d7
  rmetzger

  committed
  b86a3d7

  Copy full SHA for b86a3d7

Commits on Jan 3, 2017

• [FLINK-4861][hotfix] Fix change-scala-version script for opt assembly

  rmetzger

  committed
  1358753

  Copy full SHA for 1358753

Commits on Dec 20, 2016

• [build system] Update version to 1.3-SNAPSHOT

  rmetzger

  committed
  fd39270

  Copy full SHA for fd39270

Commits on Dec 15, 2016

• [FLINK-4446] Remove Flume connector (now in Bahir)

  rmetzger

  committed
  d84599e

  Copy full SHA for d84599e

Commits on Dec 14, 2016

• [FLINK4429] Remove redis connector (now in Apache Bahir)

  rmetzger

  committed
  8038ae4

  Copy full SHA for 8038ae4

Commits on Dec 8, 2016

• [FLINK-5039] Bump Avro version to 1.7.7.

  Show description for 2d8f03e
  

  rmetzger

  authored and

  fhueske

  committed
  2d8f03e

  Copy full SHA for 2d8f03e

Commits on Nov 30, 2016

• [FLINK-4895] Drop Hadoop1 support and remove related build infrastructure

  Show description for ac7d871
  rmetzger

  committed
  ac7d871

  Copy full SHA for ac7d871

Commits on Nov 23, 2016

• [hotfix] [streaming] Fix type extraction for joined streams.

  Show description for 16ee4a5
  

  rmetzger

  authored and

  fhueske

  committed
  16ee4a5

  Copy full SHA for 16ee4a5

• [hotfix][docs] Stream joins don't support tuple position keys

  

  rmetzger

  authored and

  fhueske

  committed
  3458a66

  Copy full SHA for 3458a66

Commits on Oct 21, 2016

• [FLINK-4878][tests] Log test failure cause on INFO level

  rmetzger

  committed
  7398fdb

  Copy full SHA for 7398fdb

Commits on Oct 14, 2016

• [FLINK-3660][hotfix] Add missing default value in ConfigConstants

  rmetzger

  committed
  5dc624b

  Copy full SHA for 5dc624b

• [FLINK-3660] Measure latency and exposes them via a metric

  Show description for a612b99
  rmetzger

  committed
  a612b99

  Copy full SHA for a612b99

Commits on Oct 13, 2016

• [hotfix][kafka] Backport Kafka09FetcherTest for Kafka010

  Show description for 3d5bca0
  rmetzger

  committed
  3d5bca0

  Copy full SHA for 3d5bca0

Commits on Oct 12, 2016

• [hotfix][kafka] Undo DataGenerators changes (use inline kafka producer again

  rmetzger

  committed
  744f8eb

  Copy full SHA for 744f8eb

• [FLINK-3706] Fix YARN test instability

  Show description for 7b79c8b
  rmetzger

  committed
  7b79c8b

  Copy full SHA for 7b79c8b

Commits on Oct 11, 2016

• [FLINK-4035] Refactor the Kafka 0.10 connector to be based upon the 0.9 connector

  Show description for 6731ec1
  rmetzger

  committed
  6731ec1

  Copy full SHA for 6731ec1

Commits on Aug 29, 2016

• [hotfix][quickstarts] Remove Jodatime exclusion

  rmetzger

  committed
  c2585c6

  Copy full SHA for c2585c6

Commits on Aug 25, 2016

• [FLINK-3823] Fix travis log upload & upload logs to transfer.sh (14 days)

  rmetzger

  committed
  444315a

  Copy full SHA for 444315a

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

Pagination

Previous

Next