awslabs/amazon-kinesis-connector-flink issues and pull requests

#66 - Backport fixes for full compatibility with Flink 1.13

Pull Request - State: open - Opened by elphastori 11 months ago

#65 - AWS Kinesis Stream read from different account fails after upgrade to flink-connector-kinesis 1.15.2

Issue - State: open - Opened by spachari-im over 1 year ago

#64 - (Python) Unable to convert kinesis table into datastream

Issue - State: closed - Opened by mattfysh almost 2 years ago - 4 comments

#63 - Bump jackson-databind from 2.12.7 to 2.13.4.1

Pull Request - State: closed - Opened by dependabot[bot] almost 2 years ago - 2 comments
Labels: dependencies

#62 - Update AWS Regions validation to allow for future AWS regions

Pull Request - State: closed - Opened by hlteoh37 about 2 years ago

#62 - Update AWS Regions validation to allow for future AWS regions

Pull Request - State: closed - Opened by hlteoh37 about 2 years ago

#61 - Update AWS Regions validation to allow for future AWS regions

Pull Request - State: closed - Opened by hlteoh37 about 2 years ago

#60 - Bump Jackson version to 2.12.7 to address CVE-2020-36518

Pull Request - State: closed - Opened by dannycranmer about 2 years ago

#60 - Bump Jackson version to 2.12.7 to address CVE-2020-36518

Pull Request - State: closed - Opened by dannycranmer about 2 years ago

#59 - Bump Jackson version to 2.12.7 to address CVE-2020-36518

Pull Request - State: closed - Opened by dannycranmer about 2 years ago

#59 - Bump Jackson version to 2.12.7 to address CVE-2020-36518

Pull Request - State: closed - Opened by dannycranmer about 2 years ago

#58 - Publish the latest version to Maven central

Issue - State: closed - Opened by vitaliislobodianyk-okta about 2 years ago - 2 comments

#57 - Updating AWS SDK versions for Kinesis connectors and using RegionUtil…

Pull Request - State: closed - Opened by dannycranmer about 2 years ago

#57 - Updating AWS SDK versions for Kinesis connectors and using RegionUtil…

Pull Request - State: closed - Opened by dannycranmer about 2 years ago

#56 - Bump jackson-databind from 2.12.1 to 2.12.6.1

Pull Request - State: closed - Opened by dependabot[bot] about 2 years ago - 2 comments
Labels: dependencies

#56 - Bump jackson-databind from 2.12.1 to 2.12.6.1

Pull Request - State: closed - Opened by dependabot[bot] about 2 years ago - 2 comments
Labels: dependencies

#55 - Updating AWS SDK versions for Kinesis connectors and using RegionUtil…

Pull Request - State: closed - Opened by dannycranmer about 2 years ago

#55 - Updating AWS SDK versions for Kinesis connectors and using RegionUtil…

Pull Request - State: closed - Opened by dannycranmer about 2 years ago

#54 - SequenceNumber class is not POJO type

Pull Request - State: closed - Opened by Cyberness over 2 years ago - 2 comments

#54 - SequenceNumber class is not POJO type

Pull Request - State: closed - Opened by Cyberness over 2 years ago - 2 comments

#53 - Add STS regional endpoint when assuming role

Pull Request - State: closed - Opened by 0xNacho over 2 years ago - 3 comments

#52 - Update log4j test dependency to v2.17.1

Pull Request - State: closed - Opened by dannycranmer over 2 years ago

#52 - Update log4j test dependency to v2.17.1

Pull Request - State: closed - Opened by dannycranmer over 2 years ago

#51 - Getting IOException/StacklessClosedChannelException when consuming data from Kinesis

Issue - State: open - Opened by leonxu8 almost 3 years ago - 1 comment

#51 - Getting IOException/StacklessClosedChannelException when consuming data from Kinesis

Issue - State: open - Opened by leonxu8 almost 3 years ago - 1 comment

#50 - AmazonKinesisException when authenticating Kinesis through AWS SSO (profile)

Issue - State: open - Opened by mberchon almost 3 years ago

#50 - AmazonKinesisException when authenticating Kinesis through AWS SSO (profile)

Issue - State: open - Opened by mberchon almost 3 years ago

#49 - FLINK-24431 Copy Flink connector changes to release-1.0

Pull Request - State: closed - Opened by rudikershaw almost 3 years ago - 2 comments

#49 - FLINK-24431 Copy Flink connector changes to release-1.0

Pull Request - State: closed - Opened by rudikershaw almost 3 years ago - 2 comments

#48 - FLINK-24431 Copy Flink connector changes to master

Pull Request - State: closed - Opened by rudikershaw almost 3 years ago

#48 - FLINK-24431 Copy Flink connector changes to master

Pull Request - State: closed - Opened by rudikershaw almost 3 years ago

#47 - SequenceNumber class is not POJO type

Issue - State: open - Opened by Cyberness about 3 years ago - 2 comments

#47 - SequenceNumber class is not POJO type

Issue - State: open - Opened by Cyberness about 3 years ago - 2 comments

#46 - Backport v2.2.0 fixes to v1.x

Pull Request - State: closed - Opened by dannycranmer about 3 years ago

#46 - Backport v2.2.0 fixes to v1.x

Pull Request - State: closed - Opened by dannycranmer about 3 years ago

#45 - Unregistering metric reporting for closed shards

Pull Request - State: closed - Opened by elphastori about 3 years ago

#45 - Unregistering metric reporting for closed shards

Pull Request - State: closed - Opened by elphastori about 3 years ago

#44 - Flink Kinesis EFO keep job restart forever after expired first 5 minutes

Issue - State: closed - Opened by totten25 about 3 years ago - 1 comment

#44 - Flink Kinesis EFO keep job restart forever after expired first 5 minutes

Issue - State: closed - Opened by totten25 about 3 years ago - 1 comment

#43 - Unregistering metric reporting for closed shards

Pull Request - State: closed - Opened by elphastori about 3 years ago - 1 comment

#43 - Unregistering metric reporting for closed shards

Pull Request - State: closed - Opened by elphastori about 3 years ago - 1 comment

#42 - Increasing read timeout to 6 minutes and enabling TCP keep alive for EFO

Pull Request - State: closed - Opened by dannycranmer about 3 years ago

#42 - Increasing read timeout to 6 minutes and enabling TCP keep alive for EFO

Pull Request - State: closed - Opened by dannycranmer about 3 years ago

#41 - Populate ClientConfiguration from properties for EFO

Pull Request - State: closed - Opened by dannycranmer about 3 years ago

#41 - Populate ClientConfiguration from properties for EFO

Pull Request - State: closed - Opened by dannycranmer about 3 years ago

#40 - Refactor to prevent AWS SDK/Netty threads blocking

Pull Request - State: closed - Opened by dannycranmer about 3 years ago

#40 - Refactor to prevent AWS SDK/Netty threads blocking

Pull Request - State: closed - Opened by dannycranmer about 3 years ago

#39 - Include guava:failureaccess in jar

Pull Request - State: closed - Opened by iemre over 3 years ago - 3 comments

#39 - Include guava:failureaccess in jar

Pull Request - State: closed - Opened by iemre over 3 years ago - 3 comments

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

Pull Request - State: closed - Opened by dannycranmer over 3 years ago

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

Pull Request - State: closed - Opened by dannycranmer over 3 years ago

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

Pull Request - State: closed - Opened by dannycranmer over 3 years ago

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

Pull Request - State: closed - Opened by dannycranmer over 3 years ago

#36 - Upgrade Guava version (#35)

Pull Request - State: closed - Opened by iemre over 3 years ago

#36 - Upgrade Guava version (#35)

Pull Request - State: closed - Opened by iemre over 3 years ago

#35 - Upgrade Guava version

Pull Request - State: closed - Opened by iemre over 3 years ago

#35 - Upgrade Guava version

Pull Request - State: closed - Opened by iemre over 3 years ago

#34 - Problems encountered when using aws connector to replace flink connector to connect kinesis stream in flink

Issue - State: closed - Opened by SOD-DOB over 3 years ago - 2 comments

#34 - Problems encountered when using aws connector to replace flink connector to connect kinesis stream in flink

Issue - State: closed - Opened by SOD-DOB over 3 years ago - 2 comments

#33 - Is there any difference

Issue - State: closed - Opened by Missshao over 3 years ago - 2 comments

#33 - Is there any difference

Issue - State: closed - Opened by Missshao over 3 years ago - 2 comments

#32 - [source][backport] Backporting bug fixes and improvements from v2.0.3

Pull Request - State: closed - Opened by dannycranmer over 3 years ago

#32 - [source][backport] Backporting bug fixes and improvements from v2.0.3

Pull Request - State: closed - Opened by dannycranmer over 3 years ago

#31 - [EFO][backport] Add timeout when waiting for subscription and delivering data to prevent lockup

Pull Request - State: closed - Opened by dannycranmer over 3 years ago

#31 - [EFO][backport] Add timeout when waiting for subscription and delivering data to prevent lockup

Pull Request - State: closed - Opened by dannycranmer over 3 years ago

#30 - Error occurred on EFO subscription: java.nio.channels.ClosedChannelException - (null).

Issue - State: closed - Opened by ensc-yang over 3 years ago - 2 comments

#30 - Error occurred on EFO subscription: java.nio.channels.ClosedChannelException - (null).

Issue - State: closed - Opened by ensc-yang over 3 years ago - 2 comments

#29 - `FlinkKinesisConsumer` metric groups and publication should be externally configurable

Issue - State: closed - Opened by bobtiernay-okta over 3 years ago - 1 comment

#29 - `FlinkKinesisConsumer` metric groups and publication should be externally configurable

Issue - State: closed - Opened by bobtiernay-okta over 3 years ago - 1 comment

#28 - Treating TimeoutException as Recoverable

Pull Request - State: closed - Opened by dannycranmer over 3 years ago

#28 - Treating TimeoutException as Recoverable

Pull Request - State: closed - Opened by dannycranmer over 3 years ago

#27 - A Rare UnknownHostException in Flink Kinesis Consumer

Issue - State: closed - Opened by sepulrator over 3 years ago - 3 comments

#27 - A Rare UnknownHostException in Flink Kinesis Consumer

Issue - State: closed - Opened by sepulrator over 3 years ago - 3 comments

#26 - Adding a fully shaded variant of connector for SQL client

Pull Request - State: closed - Opened by dannycranmer over 3 years ago

#26 - Adding a fully shaded variant of connector for SQL client

Pull Request - State: closed - Opened by dannycranmer over 3 years ago

#25 - Log error when shutting down Kinesis Data Fetcher. Move final clean up to the finally block

Pull Request - State: closed - Opened by dannycranmer over 3 years ago

#25 - Log error when shutting down Kinesis Data Fetcher. Move final clean up to the finally block

Pull Request - State: closed - Opened by dannycranmer over 3 years ago

#24 - Fix issue where KinesisDataFetcher.shutdownFetcher() hangs

Pull Request - State: closed - Opened by GS-KeithLee over 3 years ago

#24 - Fix issue where KinesisDataFetcher.shutdownFetcher() hangs

Pull Request - State: closed - Opened by GS-KeithLee over 3 years ago

#23 - An exception in `KinesisDataFetcher#shutdownFetcher` may fail to shutdown `shardConsumersExecutor` leading to job hanging

Issue - State: closed - Opened by bobtiernay-okta over 3 years ago - 3 comments

#23 - An exception in `KinesisDataFetcher#shutdownFetcher` may fail to shutdown `shardConsumersExecutor` leading to job hanging

Issue - State: closed - Opened by bobtiernay-okta over 3 years ago - 3 comments

#22 - `KinesisDataFetcher#stopWithError` should log exception so that the root cause can be observed

Issue - State: closed - Opened by bobtiernay-okta over 3 years ago - 1 comment

#22 - `KinesisDataFetcher#stopWithError` should log exception so that the root cause can be observed

Issue - State: closed - Opened by bobtiernay-okta over 3 years ago - 1 comment

#21 - Confirm if `FanOutShardSubscriber#handleError` should perform `cause instanceof TimeoutException` instead of `ReadTimeoutException`

Issue - State: closed - Opened by bobtiernay-okta over 3 years ago - 3 comments

#21 - Confirm if `FanOutShardSubscriber#handleError` should perform `cause instanceof TimeoutException` instead of `ReadTimeoutException`

Issue - State: closed - Opened by bobtiernay-okta over 3 years ago - 3 comments

#20 - Test notifications

Issue - State: closed - Opened by dannycranmer over 3 years ago

#20 - Test notifications

Issue - State: closed - Opened by dannycranmer over 3 years ago

#19 - Test PR

Pull Request - State: closed - Opened by dannycranmer over 3 years ago

#19 - Test PR

Pull Request - State: closed - Opened by dannycranmer over 3 years ago

#18 - [EFO] Add timeout when waiting for subscription and delivering data to prevent lockup

Pull Request - State: closed - Opened by dannycranmer over 3 years ago

#18 - [EFO] Add timeout when waiting for subscription and delivering data to prevent lockup

Pull Request - State: closed - Opened by dannycranmer over 3 years ago

#17 - [FLINK-21661][kinesis] Fix fetch interval for polling consumer

Pull Request - State: closed - Opened by dannycranmer over 3 years ago

#17 - [FLINK-21661][kinesis] Fix fetch interval for polling consumer

Pull Request - State: closed - Opened by dannycranmer over 3 years ago

#16 - Improving error handling when source is interrupted during job failure/cancellation

Pull Request - State: closed - Opened by dannycranmer over 3 years ago

#16 - Improving error handling when source is interrupted during job failure/cancellation

Pull Request - State: closed - Opened by dannycranmer over 3 years ago

#16 - Improving error handling when source is interrupted during job failure/cancellation

Pull Request - State: closed - Opened by dannycranmer over 3 years ago

#15 - .

Issue - State: closed - Opened by aleksandersumowski over 3 years ago

#15 - .

Issue - State: closed - Opened by aleksandersumowski over 3 years ago

#15 - .

Issue - State: closed - Opened by aleksandersumowski over 3 years ago

#14 - Test issue

Issue - State: closed - Opened by dannycranmer over 3 years ago

GitHub / awslabs/amazon-kinesis-connector-flink issues and pull requests