Commits

Branch selector

 master

User selector

dannycranmer

Datepicker

All time

Commit History

Commits on Nov 22, 2022

• [FLINK-29938][Connectors/Base] Add open() Method to AsyncSink ElementConverter (apache#21265)

  dannycranmer

  authored
  91c4d86

  Copy full SHA for 91c4d86

Commits on Oct 31, 2022

• [hotfix][docs] Adding Amazon Kinesis Data Firehose connector to datastream connectors overview

  dannycranmer

  committed
  4e860b6

  Copy full SHA for 4e860b6

Commits on Oct 21, 2022

• [hotfix][docs] Fix Kinesis EFO deregistration strategy for EAGER

  dannycranmer

  committed
  8645db0

  Copy full SHA for 8645db0

Commits on Sep 27, 2022

• [FLINK-14896][connectors/kinesis] Shade and relocate Jackson dependencies

  dannycranmer

  committed
  54f81c4

  Copy full SHA for 54f81c4

Commits on Sep 6, 2022

• [FLINK-29205][connectors/kinesis] Passthrough use config to HTTP client when constructing Async Client for Kinesis EFO

  dannycranmer

  committed
  cb32dad

  Copy full SHA for cb32dad

Commits on Aug 17, 2022

• [FLINK-28861][table][docs] Update "upgrading" documentation to include notice regarding the Table API operator issue

  dannycranmer

  committed
  f8bfb59

  Copy full SHA for f8bfb59

Commits on Aug 9, 2022

• [FLINK-28094][kinesis][glue] Updating AWS SDK versions for Kinesis connectors and Glue Schema Registry formats

  dannycranmer

  committed
  d2704b1

  Copy full SHA for d2704b1

Commits on Feb 16, 2022

• [FLINK-26118][connectors/common] Add support for AsyncSink to downscale with state. AsyncSinkWriter can be restored from multiple BufferedRequestState

  dannycranmer

  committed
  979313a

  Copy full SHA for 979313a

• [FLINK-26118][connectors/common] Setting defaults in test to reduce test complexity

  dannycranmer

  committed
  fcf8c6d

  Copy full SHA for fcf8c6d

• [FLINK-26119][connectors/common] Switching AsyncSinkWriterStateSerializer from @internal to @PublicEvolving

  dannycranmer

  committed
  85bc4e3

  Copy full SHA for 85bc4e3

Commits on Jan 11, 2022

• [FLINK-25107][formats/gsr] Migrate tests to use Assert4J

  dannycranmer

  committed
  785ca59

  Copy full SHA for 785ca59

• [FLINK-25107][formats/gsr] Adding support to define AWS Credential Provider from property map, fixing e2e tests

  dannycranmer

  committed
  46e1e60

  Copy full SHA for 46e1e60

Commits on Sep 26, 2021

• [hotfix][docs] Fix typo for 'exactly-once' in docs

  dannycranmer

  committed
  cd7bf3b

  Copy full SHA for cd7bf3b

Commits on Aug 16, 2021

• [FLINK-23802][kinesis][efo] Request next record from the Flink source thread rather than the AWS SDK response thread. Increase Read Timeout to 6m, higher than the maximum Shard subscription duratio…

  Show description for ac8c5a2
  dannycranmer

  committed
  ac8c5a2

  Copy full SHA for ac8c5a2

Commits on Jun 19, 2021

• [FLINK-18182][kinesis] Adding cloudwatch dependency for AWS DynamoDB stream adapter

  dannycranmer

  committed
  a5a9d84

  Copy full SHA for a5a9d84

• [FLINK-18182][kinesis] Fixing bad shading of AWS SDK config file, resulting in runtime errors when consuming using EFO

  dannycranmer

  committed
  a330d43

  Copy full SHA for a330d43

Commits on Jun 18, 2021

• [FLINK-18182][kinesis] Updating to latest AWS SDK for Kinesis connector

  dannycranmer

  committed
  a9a5c1e

  Copy full SHA for a9a5c1e

Commits on Apr 28, 2021

• [FLINK-22479[Kinesis][Consumer] Potential lock-up under error condition

  dannycranmer

  committed
  11f5abc

  Copy full SHA for 11f5abc

Commits on Mar 25, 2021

• [FLINK-21933][kinesis] EFO consumer treats interrupts as retryable exceptions (apache#15347)

  dannycranmer

  committed
  888551e

  Copy full SHA for 888551e

• [FLINK-21661][kinesis] Fix fetch interval for polling consumer (apache#15157)

  dannycranmer

  committed
  c7eb397

  Copy full SHA for c7eb397

Commits on Mar 19, 2021

• [FLINK-21875][hotfix] Fix compilation error in IntelliJ. Removing reliance on shaded classes. (apache#15290)

  dannycranmer

  authored
  9ee91ef

  Copy full SHA for 9ee91ef

Commits on Mar 13, 2021

• [FLINK-20042][kinesis] Adding Kinesis Table API e2e test using the Java framework (apache#15085)

  Show description for 195298a
  dannycranmer

  authored
  195298a

  Copy full SHA for 195298a

Commits on Mar 12, 2021

• [FLINK-17441][kinesis][test-stability] Updating test to assert if timeout occurs waiting for records (apache#15160)

  dannycranmer

  authored
  1170f80

  Copy full SHA for 1170f80

Commits on Dec 21, 2020

• [FLINK-20629][kinesis] Migrate from DescribeStream to DescribeStreamSummary

  Show description for d900d90
  

  dannycranmer

  authored and

  tzulitai

  committed
  d900d90

  Copy full SHA for d900d90

• [FLINK-20630][dynamodb] DynamoDB Streams Consumer fails to consume from Latest

  Show description for 1fcbdb1
  

  dannycranmer

  authored and

  tzulitai

  committed
  1fcbdb1

  Copy full SHA for 1fcbdb1

Commits on Nov 16, 2020

• [FLINK-20043][kinesis] Add flink-sql-connector-kinesis module for SQL client

  Show description for 05b6124
  

  dannycranmer

  authored and

  twalthr

  committed
  05b6124

  Copy full SHA for 05b6124

Commits on Nov 14, 2020

• [FLINK-20088][kinesis] Fix issue encountered when Polling consumer using timestamp with empty shard

  Show description for d332ff4
  

  dannycranmer

  authored and

  tzulitai

  committed
  d332ff4

  Copy full SHA for d332ff4

Commits on Nov 4, 2020

• [FLINK-19899][Kinesis][EFO] Optimise error handling to use a separate exception delivery mechanism

  Show description for 325fb24
  

  dannycranmer

  authored and

  tzulitai

  committed
  325fb24

  Copy full SHA for 325fb24

Commits on Oct 20, 2020

• [FLINK-19716][Kinesis][EFO] Unable to use Assume Role with EFO record publisher

  Show description for f4e4046
  

  dannycranmer

  authored and

  tzulitai

  committed
  f4e4046

  Copy full SHA for f4e4046

Commits on Sep 21, 2020

• [FLINK-18661][Kinesis] Stream consumer Registration/Deregistration

  

  dannycranmer

  authored and

  tzulitai

  committed
  ad4e9a6

  Copy full SHA for ad4e9a6

• [FLINK-18515][Kinesis] Adding FanOutRecordPublisher for Kinesis EFO support

  Show description for bbcd0c7
  

  dannycranmer

  authored and

  tzulitai

  committed
  bbcd0c7

  Copy full SHA for bbcd0c7

Commits on Sep 18, 2020

• [FLINK-18870][Kinesis] Update Kinesis Consumer website to document EFO Feature (apache#13261)

  dannycranmer

  authored
  44bcd47

  Copy full SHA for 44bcd47

Commits on Sep 3, 2020

• [FLINK-18513][Kinesis] Omitting AWS SDK services from shaded jar

  

  dannycranmer

  authored and

  tzulitai

  committed
  34925af

  Copy full SHA for 34925af

• [FLINK-18513][Kinesis] Inverting dependency control of KinesisProxyV2

  Show description for 3423bb8
  

  dannycranmer

  authored and

  tzulitai

  committed
  3423bb8

  Copy full SHA for 3423bb8

• [FLINK-18513][Kinesis] Adding explicit CBOR dependency to fix runtime issue

  

  dannycranmer

  authored and

  tzulitai

  committed
  ddf7590

  Copy full SHA for ddf7590

Pagination

Previous

Next