[jira] [Created] (FLINK-28148) Unable to load jar connector to a Python Table API app

Zichen Liu created FLINK-28148: -- Summary: Unable to load jar connector to a Python Table API app Key: FLINK-28148 URL: https://issues.apache.org/jira/browse/FLINK-28148 Project: Flink Issue Type

[jira] [Created] (FLINK-28027) Initialise Async Sink maximum number of in flight messages to low number for rate limiting strategy

Zichen Liu created FLINK-28027: -- Summary: Initialise Async Sink maximum number of in flight messages to low number for rate limiting strategy Key: FLINK-28027 URL: https://issues.apache.org/jira/browse/FLINK-28027

[jira] [Created] (FLINK-28007) Tests for AWS Connectors Using SDK v2 to use Synchronous Clients

Zichen Liu created FLINK-28007: -- Summary: Tests for AWS Connectors Using SDK v2 to use Synchronous Clients Key: FLINK-28007 URL: https://issues.apache.org/jira/browse/FLINK-28007 Project: Flink

[jira] [Created] (FLINK-27670) Python wrappers for Kinesis Sinks

Zichen Liu created FLINK-27670: -- Summary: Python wrappers for Kinesis Sinks Key: FLINK-27670 URL: https://issues.apache.org/jira/browse/FLINK-27670 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-27537) Remove requirement for Async Sink's RequestEntryT to be serializable

Zichen Liu created FLINK-27537: -- Summary: Remove requirement for Async Sink's RequestEntryT to be serializable Key: FLINK-27537 URL: https://issues.apache.org/jira/browse/FLINK-27537 Project: Flink

[jira] [Created] (FLINK-27536) Rename method parameter in AsyncSinkWriter

Zichen Liu created FLINK-27536: -- Summary: Rename method parameter in AsyncSinkWriter Key: FLINK-27536 URL: https://issues.apache.org/jira/browse/FLINK-27536 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-27505) Add javadoc comments to AsyncSinkBase

Zichen Liu created FLINK-27505: -- Summary: Add javadoc comments to AsyncSinkBase Key: FLINK-27505 URL: https://issues.apache.org/jira/browse/FLINK-27505 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-26589) Update the logging level of Kinesis Streams and Firehose sinks

Zichen Liu created FLINK-26589: -- Summary: Update the logging level of Kinesis Streams and Firehose sinks Key: FLINK-26589 URL: https://issues.apache.org/jira/browse/FLINK-26589 Project: Flink I

[jira] [Created] (FLINK-26309) Add a polling strategy to determine whether Localstack test container has started

Zichen Liu created FLINK-26309: -- Summary: Add a polling strategy to determine whether Localstack test container has started Key: FLINK-26309 URL: https://issues.apache.org/jira/browse/FLINK-26309 Project

[jira] [Created] (FLINK-26305) KinesisFirehoseSinkITCase writes duplicates to Localstack

Zichen Liu created FLINK-26305: -- Summary: KinesisFirehoseSinkITCase writes duplicates to Localstack Key: FLINK-26305 URL: https://issues.apache.org/jira/browse/FLINK-26305 Project: Flink Issue T

[jira] [Created] (FLINK-26300) KinesisFirehoseSinkITCase failed on azure IOException

Zichen Liu created FLINK-26300: -- Summary: KinesisFirehoseSinkITCase failed on azure IOException Key: FLINK-26300 URL: https://issues.apache.org/jira/browse/FLINK-26300 Project: Flink Issue Type:

[jira] [Created] (FLINK-25977) Close sink client and sink http client for KDS/KDF Sinks

Zichen Liu created FLINK-25977: -- Summary: Close sink client and sink http client for KDS/KDF Sinks Key: FLINK-25977 URL: https://issues.apache.org/jira/browse/FLINK-25977 Project: Flink Issue Ty

[jira] [Created] (FLINK-25976) Update the KDS and KDF Sink's defaults & update the docs

Zichen Liu created FLINK-25976: -- Summary: Update the KDS and KDF Sink's defaults & update the docs Key: FLINK-25976 URL: https://issues.apache.org/jira/browse/FLINK-25976 Project: Flink Issue Ty

[jira] [Created] (FLINK-25948) KDS / KDF Sink should call .close() to clean up resources

Zichen Liu created FLINK-25948: -- Summary: KDS / KDF Sink should call .close() to clean up resources Key: FLINK-25948 URL: https://issues.apache.org/jira/browse/FLINK-25948 Project: Flink Issue T

[jira] [Created] (FLINK-25945) Intermittent Failures on KDF AZP 2

Zichen Liu created FLINK-25945: -- Summary: Intermittent Failures on KDF AZP 2 Key: FLINK-25945 URL: https://issues.apache.org/jira/browse/FLINK-25945 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-25944) Intermittent Failures on KDF AZP

Zichen Liu created FLINK-25944: -- Summary: Intermittent Failures on KDF AZP Key: FLINK-25944 URL: https://issues.apache.org/jira/browse/FLINK-25944 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-25943) New Kinesis, Firehose to provide a state serializer

Zichen Liu created FLINK-25943: -- Summary: New Kinesis, Firehose to provide a state serializer Key: FLINK-25943 URL: https://issues.apache.org/jira/browse/FLINK-25943 Project: Flink Issue Type: N

[jira] [Created] (FLINK-25924) KDF Integration tests intermittently fails

Zichen Liu created FLINK-25924: -- Summary: KDF Integration tests intermittently fails Key: FLINK-25924 URL: https://issues.apache.org/jira/browse/FLINK-25924 Project: Flink Issue Type: New Featur

[jira] [Created] (FLINK-25793) Kinesis Data Streams sink is not limiting throughput to the destination and therefore exceeding rate limits

Zichen Liu created FLINK-25793: -- Summary: Kinesis Data Streams sink is not limiting throughput to the destination and therefore exceeding rate limits Key: FLINK-25793 URL: https://issues.apache.org/jira/browse/FLINK-

[jira] [Created] (FLINK-25792) Async Sink Base is too being flushed too frequently resulting in backpressure even when buffer is near empty

Zichen Liu created FLINK-25792: -- Summary: Async Sink Base is too being flushed too frequently resulting in backpressure even when buffer is near empty Key: FLINK-25792 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-25737) Chinese Translation - Add documentation for Firehose Async Sink

Zichen Liu created FLINK-25737: -- Summary: Chinese Translation - Add documentation for Firehose Async Sink Key: FLINK-25737 URL: https://issues.apache.org/jira/browse/FLINK-25737 Project: Flink

[jira] [Created] (FLINK-25736) Chinese Translation - Update documentation for Kinesis Table Api

Zichen Liu created FLINK-25736: -- Summary: Chinese Translation - Update documentation for Kinesis Table Api Key: FLINK-25736 URL: https://issues.apache.org/jira/browse/FLINK-25736 Project: Flink

[jira] [Created] (FLINK-25735) Chinese Translation - Add documentation for KDS Async Sink

Zichen Liu created FLINK-25735: -- Summary: Chinese Translation - Add documentation for KDS Async Sink Key: FLINK-25735 URL: https://issues.apache.org/jira/browse/FLINK-25735 Project: Flink Issue

[jira] [Created] (FLINK-25731) Mark FlinkKinesisProducer/FlinkKinesisConsumer as deprecated

Zichen Liu created FLINK-25731: -- Summary: Mark FlinkKinesisProducer/FlinkKinesisConsumer as deprecated Key: FLINK-25731 URL: https://issues.apache.org/jira/browse/FLINK-25731 Project: Flink Iss

[jira] [Created] (FLINK-25729) Replace the deprecated FlinkKinesisConsumer with a Kinesis Consumer based on the AWS SDK for Java 2.x

Zichen Liu created FLINK-25729: -- Summary: Replace the deprecated FlinkKinesisConsumer with a Kinesis Consumer based on the AWS SDK for Java 2.x Key: FLINK-25729 URL: https://issues.apache.org/jira/browse/FLINK-25729

[jira] [Created] (FLINK-25692) Documentation for Kinesis Firehose Sink

Zichen Liu created FLINK-25692: -- Summary: Documentation for Kinesis Firehose Sink Key: FLINK-25692 URL: https://issues.apache.org/jira/browse/FLINK-25692 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-25408) Chinese Translation - Add documentation for KDS Async Sink

Zichen Liu created FLINK-25408: -- Summary: Chinese Translation - Add documentation for KDS Async Sink Key: FLINK-25408 URL: https://issues.apache.org/jira/browse/FLINK-25408 Project: Flink Issue

[jira] [Created] (FLINK-24905) KDS implementation of Async Sink Table API

Zichen Liu created FLINK-24905: -- Summary: KDS implementation of Async Sink Table API Key: FLINK-24905 URL: https://issues.apache.org/jira/browse/FLINK-24905 Project: Flink Issue Type: New Featur

[jira] [Created] (FLINK-24904) Add documentation for KDS Async Sink

Zichen Liu created FLINK-24904: -- Summary: Add documentation for KDS Async Sink Key: FLINK-24904 URL: https://issues.apache.org/jira/browse/FLINK-24904 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-24602) Include diffs for configuration documentation page

Zichen Liu created FLINK-24602: -- Summary: Include diffs for configuration documentation page Key: FLINK-24602 URL: https://issues.apache.org/jira/browse/FLINK-24602 Project: Flink Issue Type: Im

[jira] [Created] (FLINK-24370) [FLIP-171] Documentation for Generic AsyncSinkBase

Zichen Liu created FLINK-24370: -- Summary: [FLIP-171] Documentation for Generic AsyncSinkBase Key: FLINK-24370 URL: https://issues.apache.org/jira/browse/FLINK-24370 Project: Flink Issue Type: Ne

[jira] [Created] (FLINK-24278) [FLIP-171] Async Sink Base Sink Developer Guide for Documentation

Zichen Liu created FLINK-24278: -- Summary: [FLIP-171] Async Sink Base Sink Developer Guide for Documentation Key: FLINK-24278 URL: https://issues.apache.org/jira/browse/FLINK-24278 Project: Flink

[jira] [Created] (FLINK-24234) [FLIP-171] Byte Based & Time Based Flushing for AsyncSinkBase

Zichen Liu created FLINK-24234: -- Summary: [FLIP-171] Byte Based & Time Based Flushing for AsyncSinkBase Key: FLINK-24234 URL: https://issues.apache.org/jira/browse/FLINK-24234 Project: Flink Is

[jira] [Created] (FLINK-24229) [FLIP-171] DynamoDB implementation of Async Sink

Zichen Liu created FLINK-24229: -- Summary: [FLIP-171] DynamoDB implementation of Async Sink Key: FLINK-24229 URL: https://issues.apache.org/jira/browse/FLINK-24229 Project: Flink Issue Type: New

[jira] [Created] (FLINK-24228) [FLIP-171] Firehose implementation of Async Sink

Zichen Liu created FLINK-24228: -- Summary: [FLIP-171] Firehose implementation of Async Sink Key: FLINK-24228 URL: https://issues.apache.org/jira/browse/FLINK-24228 Project: Flink Issue Type: New

[jira] [Created] (FLINK-24227) [FLIP-171] KDS implementation of Async Sink

Zichen Liu created FLINK-24227: -- Summary: [FLIP-171] KDS implementation of Async Sink Key: FLINK-24227 URL: https://issues.apache.org/jira/browse/FLINK-24227 Project: Flink Issue Type: New Featu

[jira] [Created] (FLINK-24041) [FLIP-171] Generic AsyncSinkBase

Zichen Liu created FLINK-24041: -- Summary: [FLIP-171] Generic AsyncSinkBase Key: FLINK-24041 URL: https://issues.apache.org/jira/browse/FLINK-24041 Project: Flink Issue Type: New Feature