issues  

Messages by Thread

• [jira] [Assigned] (FLINK-37865) Add documentation for AsyncTableFunction Alan Sheinberg (Jira)
• [jira] [Created] (FLINK-37865) Add documentation for AsyncTableFunction Alan Sheinberg (Jira)
• [PR] Flink 1.20 with Pulsar 3.0.12 [flink-connector-pulsar] via GitHub
  • Re: [PR] Flink 1.20 with Pulsar 3.0.12 [flink-connector-pulsar] via GitHub
• [jira] [Closed] (FLINK-37763) Support multiple tables with set semantics Timo Walther (Jira)
• [PR] [hotfix] Fix typo in StreamingJobGraphGenerator config [flink] via GitHub
  • Re: [PR] [hotfix] Fix typo in StreamingJobGraphGenerator config [flink] via GitHub
  • Re: [PR] [hotfix] Fix typo in StreamingJobGraphGenerator config [flink] via GitHub
  • Re: [PR] [hotfix] Fix typo in StreamingJobGraphGenerator config [flink] via GitHub
• [jira] [Commented] (FLINK-28847) Typo in FileSinkProgram.java in file-sink-file-test module Rion Williams (Jira)
• [PR] [FLINK-28847] Removed Extraneous Semicolon [flink] via GitHub
  • Re: [PR] [FLINK-28847] Removed Extraneous Semicolon [flink] via GitHub
  • Re: [PR] [FLINK-28847] Removed Extraneous Semicolon [flink] via GitHub
  • Re: [PR] [FLINK-28847] Removed Extraneous Semicolon [flink] via GitHub
  • Re: [PR] [FLINK-28847] Removed Extraneous Semicolon [flink] via GitHub
• [jira] [Updated] (FLINK-28847) Typo in FileSinkProgram.java in file-sink-file-test module ASF GitHub Bot (Jira)
• [PR] Bump commons-beanutils:commons-beanutils from 1.9.4 to 1.11.0 in /flink-filesystems/flink-s3-fs-presto [flink] via GitHub
  • Re: [PR] Bump commons-beanutils:commons-beanutils from 1.9.4 to 1.11.0 in /flink-filesystems/flink-s3-fs-presto [flink] via GitHub
• [PR] Bump commons-beanutils:commons-beanutils from 1.8.3 to 1.10.1.redhat-00001 in /flink-yarn [flink] via GitHub
  • Re: [PR] Bump commons-beanutils:commons-beanutils from 1.8.3 to 1.10.1.redhat-00001 in /flink-yarn [flink] via GitHub
• [jira] [Resolved] (FLINK-36604) StreamingJobGraphGenerator::setOperatorConfig checks input serializer lengh Mingliang Liu (Jira)
• [jira] [Resolved] (FLINK-37812) Fix broken links to Apache Avro in doc and code Mingliang Liu (Jira)
• [jira] [Closed] (FLINK-37780) ml_predict sql function type inference and argument validation Shengkai Fang (Jira)
• [jira] [Commented] (FLINK-37780) ml_predict sql function type inference and argument validation Shengkai Fang (Jira)
• [jira] [Commented] (FLINK-37859) [umbrella] FLIP-516: Streaming Multi-Way Join Optimization Gustavo de Morais (Jira)
  • [jira] [Commented] (FLINK-37859) [umbrella] FLIP-516: Streaming Multi-Way Join Optimization dalongliu (Jira)
• [jira] [Created] (FLINK-37864) Extend DynamicKafkaSource to allow for cluster-specific OffsetsInitializer Joey Pereira (Jira)
• [jira] [Updated] (FLINK-37863) DynamicKafkaSource support in PyFlink ASF GitHub Bot (Jira)
• [PR] [FLINK-37863] add DynamicKafkaSource interface [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-37863] add DynamicKafkaSource interface [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-37863] add DynamicKafkaSource interface [flink-connector-kafka] via GitHub
• [jira] [Created] (FLINK-37863) DynamicKafkaSource support in PyFlink Joey Pereira (Jira)
• [jira] [Created] (FLINK-37862) Implement data type improvements for StructuredType Timo Walther (Jira)
• [jira] [Updated] (FLINK-37814) FLIP-516: Add RIGHT JOIN to LEFT JOIN rule Gustavo de Morais (Jira)
• [jira] [Updated] (FLINK-37701) The testRecoverLocallyFromProcessCrashWithWorkingDirectory test failed of azure cron adaptive scheduler pipeline Robert Metzger (Jira)
  • [jira] [Updated] (FLINK-37701) The testRecoverLocallyFromProcessCrashWithWorkingDirectory test failed of azure cron adaptive scheduler pipeline Robert Metzger (Jira)
• [jira] [Created] (FLINK-37861) FLIP-520: Simplify StructuredType handling Timo Walther (Jira)
• [jira] [Closed] (FLINK-37829) ChangelogNormalize fails with CURRENT_WATERMARK in the filter condition Dawid Wysakowicz (Jira)
• [jira] [Comment Edited] (FLINK-37246) Delegation Token expire after enable delegation token framework Ferenc Csaky (Jira)
• [jira] [Commented] (FLINK-37246) Delegation Token expire after enable delegation token framework Ferenc Csaky (Jira)
• [jira] [Updated] (FLINK-37246) Delegation Token expire after enable delegation token framework Ferenc Csaky (Jira)
• [PR] Kubernetes Operator 1.12.0 release [flink-web] via GitHub
  • Re: [PR] Kubernetes Operator 1.12.0 release [flink-web] via GitHub
  • Re: [PR] Kubernetes Operator 1.12.0 release [flink-web] via GitHub
  • Re: [PR] Kubernetes Operator 1.12.0 release [flink-web] via GitHub
  • Re: [PR] Kubernetes Operator 1.12.0 release [flink-web] via GitHub
  • Re: [PR] Kubernetes Operator 1.12.0 release [flink-web] via GitHub
  • Re: [PR] Kubernetes Operator 1.12.0 release [flink-web] via GitHub
  • Re: [PR] Kubernetes Operator 1.12.0 release [flink-web] via GitHub
  • Re: [PR] Kubernetes Operator 1.12.0 release [flink-web] via GitHub
  • Re: [PR] Kubernetes Operator 1.12.0 release [flink-web] via GitHub
  • Re: [PR] Kubernetes Operator 1.12.0 release [flink-web] via GitHub
  • Re: [PR] Kubernetes Operator 1.12.0 release [flink-web] via GitHub
• [jira] [Commented] (FLINK-37821) JobMasterTriggerSavepointITCase.testDoNotCancelJobIfSavepointFails test failed of azure ci dalongliu (Jira)
• [jira] [Closed] (FLINK-37821) JobMasterTriggerSavepointITCase.testDoNotCancelJobIfSavepointFails test failed of azure ci dalongliu (Jira)
• [jira] [Comment Edited] (FLINK-37687) Bump flink-connector-aws to 2.0 Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-37860) [paimon-connector]Fix Committer.createContext not passing OperatorStateStore correctly ASF GitHub Bot (Jira)
• [PR] [FLINK-37860][pipeline-connector/paimon]Fix Committer.createContext not passing OperatorStateStore correctly [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37860][pipeline-connector/paimon]Fix Committer.createContext not passing OperatorStateStore correctly [flink-cdc] via GitHub
• [jira] [Created] (FLINK-37860) [paimon-connector]Fix Committer.createContext not passing OperatorStateStore correctly MOBIN (Jira)
• [jira] [Comment Edited] (FLINK-37767) Update ref version for es connector Weijie Guo (Jira)
  • [jira] [Comment Edited] (FLINK-37767) Update ref version for es connector Weijie Guo (Jira)
• [PR] Develop [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc] via GitHub
• [PR] [FLINK-37687] Introduce support for Flink 2.0 in flink-connector-aws [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-37687] Introduce support for Flink 2.0 in flink-connector-aws [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-37687] Introduce support for Flink 2.0 in flink-connector-aws [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-37687] Introduce support for Flink 2.0 in flink-connector-aws [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-37687] Introduce support for Flink 2.0 in flink-connector-aws [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-37687] Introduce support for Flink 2.0 in flink-connector-aws [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-37687] Introduce support for Flink 2.0 in flink-connector-aws [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-37687] Introduce support for Flink 2.0 in flink-connector-aws [flink-connector-aws] via GitHub
• [PR] [BP-1.20][FLINK-37767][doc] Update reference branch/version for es connector [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-37767][doc] Update reference branch/version for es connector [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-37767][doc] Update reference branch/version for es connector [flink] via GitHub
• [jira] (FLINK-37687) Bump flink-connector-aws to 2.0 Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-5783) flink-connector-kinesis java.lang.NoClassDefFoundError: org/apache/http/conn/ssl/SSLSocketFactory Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-33167) Run IT tests against Kinesalite if AWS credentials are not present Hong Liang Teoh (Jira)
• [PR] Bump connector version to 5.1.0 [flink-connector-aws] via GitHub
• [jira] [Updated] (FLINK-36828) Implement example for customers to perform KPL Deaggregation Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-26300) KinesisFirehoseSinkITCase failed on azure IOException Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-37853) FLIP-530: Dynamic job configuration Roman Khachatryan (Jira)
• [jira] [Updated] (FLINK-33132) Flink Connector Redshift Implementation (Table-API) Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-25949) [FLIP-171] Kinesis Firehose sink builder falls back to wrong http protocol. Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-26069) KinesisFirehoseSinkITCase failed due to org.testcontainers.containers.ContainerLaunchException: Container startup failed Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-33194) AWS Connector should directly depend on 3rd-party libs instead of flink-shaded repo Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-36204) Fix dropping records when consuming from LATEST and having a restore from expired snapshot Hong Liang Teoh (Jira)
• [jira] [Reopened] (FLINK-34342) Address Shard Consistency Issue for DDB Streams Source Hong Liang Teoh (Jira)
  • [jira] [Reopened] (FLINK-34342) Address Shard Consistency Issue for DDB Streams Source Hong Liang Teoh (Jira)
• [jira] [Closed] (FLINK-34342) Address Shard Consistency Issue for DDB Streams Source Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-5355) Handle AmazonKinesisException gracefully in Kinesis Streaming Connector Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-34260) Update flink-connector-aws to be compatible with updated SinkV2 interfaces Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-7673) Flink Kinesis connector - remove dependency on the ASL code Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-10358) Flink kinesis connector could throw NPE during getRecords() call Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-5953) Sample Kinesis Scala code doesn't work Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-11042) testFlinkKafkaProducerFailTransactionCoordinatorBeforeNotify is an invalid test Hong Liang Teoh (Jira)
• [jira] [Resolved] (FLINK-34342) Address Shard Consistency Issue for DDB Streams Source Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-36203) Have some way to control the polling frequency of GetRecords from SplitFetcher Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-31942) Support Conditional Writes in DynamoDB connector Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-37648) Flink Kinesis connector lost track of 1 shard. Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-37627) Restarting from a checkpoint/savepoint which coincides with shard split causes data loss Hong Liang Teoh (Jira)
• [jira] [Closed] (FLINK-36907) Bump flink-connector-aws to 1.20 Hong Liang Teoh (Jira)
• [jira] [Closed] (FLINK-37858) Migrate state processor API from source v1 to source v2 API Gabor Somogyi (Jira)
• [jira] [Updated] (FLINK-20060) Add a Collector to KinsesisDeserializationSchema Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-4627) Use Flink's PropertiesUtil in Kinesis connector to extract typed values from config properties Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-33141) Promentheus Sink Connector - Amazon Managed Prometheus Request Signer Hong Liang Teoh (Jira)
  • [jira] [Updated] (FLINK-33141) Promentheus Sink Connector - Amazon Managed Prometheus Request Signer Hong Liang Teoh (Jira)
• [jira] [Commented] (FLINK-36939) High CPU Utilization with Flink Kinesis EFO Consumer Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-35541) Introduce retry limiting for AWS connector sinks Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-36328) Making the log for child not found as debug Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-36239) DDB Streams Connector reprocessing due to DescribeStream inconsistencies for trimmed shards Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-34407) Flaky tests causing workflow timeout Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-34892) Nightly AWS connectors build fails on running python tests Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-35022) Add TypeInformed Element Converter for DynamoDbSink Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-36138) KinesisStreamsSource.build() should have helpful null errors Hong Liang Teoh (Jira)
• [jira] [Closed] (FLINK-36195) Generalized retry configuration in flink-connector-base Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-35660) Implement parent-child ordering for DDB Streams source Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-36359) IT case for DDB Streams connector Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-4194) Implement isEndOfStream() for KinesisDeserializationSchema Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-6316) Kinesis connector docs should mention that FlinkKinesisConsumer does not provide strong ordering guarantees on resharding Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-32394) Init.pos is partially stored in connector state Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-19460) AWS Kinesis Producer EXACTLY_ONCE semantic Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-31854) FLIP-307:[Phase 1] [Sink Support] Flink Connector Redshift Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-31988) Implement Python wrapper for new KDS source Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-22068) FlinkKinesisConsumerTest.testPeriodicWatermark fails on azure Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-8416) Kinesis consumer doc examples should demonstrate preferred default credentials provider Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-10492) Document generic support for configuring AwsKinesisClient in the Kinesis Consumer Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-4195) Dedicated Configuration classes for Kinesis Consumer / Producer Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-36939) High CPU Utilization with Flink Kinesis EFO Consumer Hong Liang Teoh (Jira)
• [jira] [Resolved] (FLINK-36195) Generalized retry configuration in flink-connector-base Hong Liang Teoh (Jira)
• [jira] [Reopened] (FLINK-36195) Generalized retry configuration in flink-connector-base Hong Liang Teoh (Jira)
  • [jira] [Reopened] (FLINK-36195) Generalized retry configuration in flink-connector-base Hong Liang Teoh (Jira)
• [jira] [Commented] (FLINK-36203) Have some way to control the polling frequency of GetRecords from SplitFetcher Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-36523) DDB Streams connector treating LATEST as TRIM_HORIZON for some cases Hong Liang Teoh (Jira)
  • [jira] [Updated] (FLINK-36523) DDB Streams connector treating LATEST as TRIM_HORIZON for some cases Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-37416) DDB Streams connector flink state inconsistency issue Hong Liang Teoh (Jira)
• [jira] [Closed] (FLINK-36204) Fix dropping records when consuming from LATEST and having a restore from expired snapshot Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-36215) Child shards are getting started with LATEST shard iterator even when parents are not expired Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-36329) DDB Streams connector not retrying some SDK exceptions Hong Liang Teoh (Jira)
  • [jira] [Updated] (FLINK-36329) DDB Streams connector not retrying some SDK exceptions Hong Liang Teoh (Jira)
• [jira] [Commented] (FLINK-37416) DDB Streams connector flink state inconsistency issue Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-27941) [JUnit5 Migration] Module: flink-connector-kinesis Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-8417) Support STSAssumeRoleSessionCredentialsProvider in FlinkKinesisConsumer Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-14039) Flink Kinesis consumer: configurable per-shard consumption rate when running in adaptive mode Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-34340) Implement DDB Streams Table API support Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-21228) Deadlock in KinesisProducer Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-6349) Enforce per-subtask record ordering on resharding for FlinkKinesisConsumer Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-29311) Unable to use http for Kinesis consumer when testing locally Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-18344) Avoid wrong check with shardId in DynamoDB Streams Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-26008) Update Kinesalite docker container reference Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-35500) DynamoDb Table API Sink fails to delete elements due to key not found Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-31946) DynamoDB Sink Allow Multiple Item Writes Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-34490) flink-connector-kinesis not correctly supporting credential chaining Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-36947) Rate limiting the GetRecord call frequency Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-25733) Create A migration guide for Kinesis Table API connector Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-21441) FlinkKinesisProducer does not forward custom endpoint Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-6503) Refactor KinesisDataFetcher to separate concerns for shard discovery Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-4574) Strengthen fetch interval implementation in Kinesis consumer Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-10536) Flink Kinesis Consumer leading to job failure due to ProvisionedThroughputExceededException Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-8556) Add proxy feature to Kinesis Connector to acces its endpoint Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-31961) Implement ExpandedQuery and OriginalQuery methods for glue in catalog Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-33068) Handle DNS errors in AWS connectors as recoverable Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-32116) FlinkKinesisConsumer cannot stop-with-savepoint when configured with watermark assigner and watermark tracker Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-16839) Connectors Kinesis metrics can be disabled Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-7622) Respect local KPL queue size in FlinkKinesisProducer when adding records to KPL client Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-32097) Implement support for Kinesis deaggregation Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-8315) Use AWSCredentialsProvider to get AWS credentials Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-34023) Expose Kinesis client retry config in sink Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-35299) FlinkKinesisConsumer does not respect StreamInitialPosition for new Kinesis Stream when restoring from snapshot Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-22473) Kinesis connector options are not listed by its factory Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-33991) Custom Error Handling for Kinesis Polling Consumer Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-33259) flink-connector-aws should use/extend the common connector workflow Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-13291) Cannot provide AWS Direct Connect ENDPOINT Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-34076) flink-connector-base missing fails kinesis table sink to create Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-18734) Add documentation for DynamoStreams Consumer CDC Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-20350) Incompatible Connectors due to Guava conflict Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-29549) Add Aws Glue Catalog support in Flink Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-32696) Promote Kinesis connector support to PublicEvolving Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-16505) Document how to use the FlinkKinesisConsumer to read a CDC stream from DynamoDB Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-36057) Allow specifying ARN for AWS connector resources Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-32007) Implement Python Wrappers for DynamoDB Connector Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-8542) Do not indefinitely store closed shard's state in the FlinkKinesisConsumer Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-20294) Expose value format metadata in Kinesis table source Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-26933) FlinkKinesisConsumer incorrectly determines shards as newly discovered when tested against Kinesalite when consuming DynamoDB streams Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-31872) Add Support for Configuring AIMD Ratelimiting strategy parameters by Sink users for KinesisStreamsSink Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-36155) ByteBuf.release() was not called before it's garbage-collected in Kinesis Connector Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-36205) DDB Streams connector should be able to resolve the stream ARN from given Table name Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-34520) Confusing MIT language in the NOTICE file Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-30092) Improve Table API experience for Flink DOUBLE type Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-11942) Flink kinesis connector throws kinesis producer daemon fatalError Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-20908) ShardConsumerFanOutTest.testStartFromLatestIsTranslatedToTimestamp test failed with AssertionError Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-35989) Document and log error on partially failed requests for AWS sinks Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-36432) FLIP-438: Amazon SQS Source Connector Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-36296) Add incremental shard discovery for DDB Streams source Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-36412) Retry strategies on Kinesis Sink Hong Liang Teoh (Jira)
  • [jira] [Updated] (FLINK-36412) Retry strategies on Kinesis Sink Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-36672) Kinesis Table API for new KDS source should infer region from streamARN Hong Liang Teoh (Jira)
• [jira] [Updated] (FLINK-36671) Kinesis Table API for new KDS source does not support metadata. Hong Liang Teoh (Jira)
• [jira] [Closed] (FLINK-36770) Support Request Timeout for AWS sinks Hong Liang Teoh (Jira)

• Earlier messages
• Later messages