Commits

Branch selector

 master

User selector

tweise

Datepicker

All time

Commit History

Commits on Sep 3, 2021

• [FLINK-24064][connector/common] HybridSource restore from savepoint

  tweise

  committed
  2984d87

Commits on Aug 29, 2021

• [FLINK-24010][connector/common] HybridSourceReader/Enumerator delegate checkpoint notifications

  tweise

  committed
  da944a8

Commits on Aug 25, 2021

• [hotfix] How to build documentation using Hugo Docker image.

  Show description for 8b307b0
  

  tweise

  authored and

  sjwiesman

  committed
  8b307b0

Commits on Aug 24, 2021

• [FLINK-22791][docs] Documentation for HybridSource

  tweise

  committed
  fb7fbd8

Commits on Aug 4, 2021

• [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

  tweise

  committed
  23b048b

Commits on May 26, 2021

• [FLINK-22778] Upgrade to JUnit 4.13

  tweise

  committed
  15b5a06

Commits on Feb 1, 2021

• [FLINK-21169][kafka] flink-connector-base dependency should be scope compile

  tweise

  committed
  d859920

Commits on Jan 27, 2021

• [FLINK-21059][kafka] KafkaSourceEnumerator does not honor consumer properties

  tweise

  committed
  a4f1174

Commits on May 5, 2020

• [FLINK-17496][kinesis] Upgrade amazon-kinesis-producer to 0.14.0

  tweise

  committed
  a737cdc

Commits on Mar 4, 2020

• [FLINK-16393][kinesis] Skip record emitter thread creation w/o source sync

  tweise

  committed
  de5f8fa

Commits on Feb 5, 2020

• [FLINK-15868][kinesis] Resolve version conflict between jackson-core and jackson-dataformat-cbor

  

  tweise

  authored and

  tillrohrmann

  committed
  e51ad13

Commits on Dec 20, 2019

• [FLINK-15301] [kinesis] Exception propagation from record emitter to source thread

  tweise

  committed
  c2c38b1

Commits on Oct 4, 2019

• [FLINK-14283][kinesis][docs] Update Kinesis consumer docs for recent feature additions

  tweise

  committed
  3f5c212

Commits on Sep 18, 2019

• [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

  tweise

  committed
  4a4a147

Commits on Aug 27, 2019

• [hotfix][kinesis] Update emit record javadoc and don't count max watermark as timeout

  tweise

  committed
  b6bd8f6

Commits on Aug 2, 2019

• [FLINK-12768][tests] Fix FlinkKinesisConsumerTest.testSourceSynchronization race condition

  Show description for 8da6965
  

  tweise

  authored and

  tillrohrmann

  committed
  8da6965

Commits on May 29, 2019

• [FLINK-10921] [kinesis] Shard watermark synchronization in Kinesis consumer

  tweise

  committed
  793a784

Commits on Mar 18, 2019

• [FLINK-9007] [kinesis] [e2e] Build Kinesis test under include-kinesis profile

  tweise

  committed
  4250819

Commits on Mar 17, 2019

• [hotfix] [FLINK-9007] [kinesis] [e2e] Disable record aggregation

  tweise

  committed
  92c7808

Commits on Mar 15, 2019

• [FLINK-9007] [kinesis] [e2e] Add Kinesis end-to-end test

  tweise

  committed
  19570c6

Commits on Mar 5, 2019

• [FLINK-11826] Ignore flaky testRateLimitedConsumer

  tweise

  committed
  56afa2e

Commits on Jan 23, 2019

• [FLINK-11048] Mark new RemoteStreamEnvironment constructor PublicEvolving

  tweise

  committed
  20fff57

Commits on Dec 20, 2018

• [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore

  Show description for bb9b176
  tweise

  committed
  bb9b176

Commits on Dec 13, 2018

• [FLINK-11145] Fix Hadoop version handling in binary release script

  tweise

  committed
  951ae9a

Commits on Nov 21, 2018

• [FLINK-5697] [kinesis] Add periodic per-shard watermark support

  Show description for f75c33d
  

  tweise

  authored and

  mxm

  committed
  f75c33d

Commits on Oct 5, 2018

• [FLINK-10279] [documentation] Make jython limitations more obvious in documentation.

  Show description for 982fa40
  

  tweise

  authored and

  mxm

  committed
  982fa40

Commits on Aug 17, 2018

• [FLINK-10020] [kinesis] Support recoverable exceptions in listShards.

  Show description for 50d076a
  

  tweise

  authored and

  tzulitai

  committed
  50d076a

Commits on Aug 1, 2018

• [FLINK-9926][Kinesis Connector] Allow for ShardConsumer override in Kinesis consumer.

  Show description for dd4b3d1
  

  tweise

  authored and

  tzulitai

  committed
  dd4b3d1

Commits on May 24, 2018

• [FLINK-9415] [scala, test] Remove ScalaStreamingMultipleProgramsTestBase

  Show description for 6e54f10
  

  tweise

  authored and

  tzulitai

  committed
  6e54f10

• [FLINK-9415] Remove reference to StreamingMultipleProgramsTestBase in docs

  

  tweise

  authored and

  tzulitai

  committed
  ce47571

Commits on May 22, 2018

• [FLINK-9402] [kinesis] Kinesis consumer configuration requires either region or endpoint.

  Show description for 9ad868c
  

  tweise

  authored and

  tillrohrmann

  committed
  9ad868c

Commits on May 2, 2018

• [FLINK-9188] [kinesis] Generic mechanism to set ClientConfiguration properties.

  Show description for fbcadbe
  

  tweise

  authored and

  tzulitai

  committed
  fbcadbe

Commits on Apr 18, 2018

• [FLINK-9124] [kinesis] Allow customization of KinesisProxy.getRecords read timeout and retry.

  Show description for 9fec5ca
  

  tweise

  authored and

  tzulitai

  committed
  9fec5ca

Commits on Feb 23, 2018

• [FLINK-8648] [kinesis] Allow for customization of emitRecordAndUpdateState in Kinesis connector.

  Show description for e75481c
  

  tweise

  authored and

  tzulitai

  committed
  e75481c

Commits on Feb 15, 2018

• [FLINK-8516] [kinesis] Allow for custom hash function for shard to subtask mapping in Kinesis consumer

  Show description for 942649e
  

  tweise

  authored and

  tzulitai

  committed
  942649e