issues  

Messages by Thread

• [jira] [Comment Edited] (FLINK-37873) 【Hbase-connector】Enable buffer flush, specify a non-existent table when writing data to hbase, the Flink task displays successful Xin Chen (Jira)
• [jira] [Commented] (FLINK-37873) 【Hbase-connector】Enable buffer flush, specify a non-existent table when writing data to hbase, the Flink task displays successful Xin Chen (Jira)
• [jira] [Updated] (FLINK-37873) 【Hbase-connector】Enable buffer flush, specify a non-existent table when writing data to hbase, the Flink task displays successful Xin Chen (Jira)
• [jira] [Created] (FLINK-37873) 【Hbase-connector】Enable buffer flush, specify a non-existent table when writing data to hbase, the Flink task displays successful Xin Chen (Jira)
• [jira] [Commented] (FLINK-36188) HBase disable buffer flush lose efficacy Xin Chen (Jira)
• [jira] [Assigned] (FLINK-37249) Remove unnecessary --add-opens/--add-exports for java.base/sun.net.util Weihua Hu (Jira)
• [jira] [Commented] (FLINK-37842) BlockingShutdownTest#testProcessShutdownBlocking test failed of azure ci dalongliu (Jira)
• [jira] [Created] (FLINK-37872) Autoscaler computes negative true processing rate Sai Sharath Dandi (Jira)
• [jira] [Updated] (FLINK-37871) Remove FlinkRelMdUtil#getJoinDistinctRowCount ASF GitHub Bot (Jira)
• [PR] [FLINK-37871][table] Remove `FlinkRelMdUtil#getJoinDistinctRowCount` [flink] via GitHub
  • Re: [PR] [FLINK-37871][table] Remove `FlinkRelMdUtil#getJoinDistinctRowCount` [flink] via GitHub
• [jira] [Created] (FLINK-37871) Remove FlinkRelMdUtil#getJoinDistinctRowCount Sergey Nuyanzin (Jira)
• Re: [PR] [FLINK-36303] PostgreSQL timestamp precision 0 not supported [flink-connector-jdbc] via GitHub
• [jira] [Updated] (FLINK-34487) Integrate tools/azure-pipelines/build-python-wheels.yml into GHA nightly workflow Ferenc Csaky (Jira)
• [jira] [Assigned] (FLINK-37869) FINISHED bouned job can't be cleanup by the Flink Kuberenetes Operator Rui Fan (Jira)
• [jira] [Created] (FLINK-37870) Unaligned checkpoint is disabled unexpectedly Rui Fan (Jira)
• [PR] Flink 36112- testing [flink] via GitHub
  • Re: [PR] Flink 36112- testing [flink] via GitHub
  • Re: [PR] Flink 36112- testing [flink] via GitHub
  • Re: [PR] Flink 36112- testing [flink] via GitHub
  • Re: [PR] Flink 36112- testing [flink] via GitHub
  • Re: [PR] Flink 36112- testing [flink] via GitHub
  • Re: [PR] Flink 36112- testing [flink] via GitHub
• [jira] [Updated] (FLINK-37869) FINISHED bouned job can't be cleanup by the Flink Kuberenetes Operator junzhong qin (Jira)
  • [jira] [Updated] (FLINK-37869) FINISHED bouned job can't be cleanup by the Flink Kuberenetes Operator junzhong qin (Jira)
  • [jira] [Updated] (FLINK-37869) FINISHED bouned job can't be cleanup by the Flink Kuberenetes Operator junzhong qin (Jira)
  • [jira] [Updated] (FLINK-37869) FINISHED bouned job can't be cleanup by the Flink Kuberenetes Operator junzhong qin (Jira)
• [jira] [Updated] (FLINK-37869) Bouned job can't be cleanup by the Flink Kuberenetes Operator junzhong qin (Jira)
• [jira] [Created] (FLINK-37869) Bouned job can't be cleanup by the Flink Kuberenetes Operator junzhong qin (Jira)
• [jira] [Created] (FLINK-37868) Respect the `maxTransferBytes` when using path copying in ForSt Zakelly Lan (Jira)
• [jira] [Updated] (FLINK-37866) Migrate glue schema registry e2e test to use aws-kinesis-streams connector Daren Wong (Jira)
  • [jira] [Updated] (FLINK-37866) Migrate glue schema registry e2e test to use aws-kinesis-streams connector Daren Wong (Jira)
  • [jira] [Updated] (FLINK-37866) Migrate glue schema registry e2e test to use aws-kinesis-streams connector Daren Wong (Jira)
• [jira] [Created] (FLINK-37867) ForSt StateBackend fail to clean up files of the half-uploaded checkpoint when using path copying Zakelly Lan (Jira)
• [jira] [Created] (FLINK-37866) Migrate glue schema registry e2e test to use aws-kinesis-streams connector Daren Wong (Jira)
• [PR] [BP-2.0][FLINK-37761][runtime] Fix unstable test testJobVertexUnFinishedAndOperatorCoordinatorNotSupportBatchSnapshot. [flink] via GitHub
  • Re: [PR] [BP-2.0][FLINK-37761][runtime] Fix unstable test testJobVertexUnFinishedAndOperatorCoordinatorNotSupportBatchSnapshot. [flink] via GitHub
  • Re: [PR] [BP-2.0][FLINK-37761][runtime] Fix unstable test testJobVertexUnFinishedAndOperatorCoordinatorNotSupportBatchSnapshot. [flink] via GitHub
• [jira] [Resolved] (FLINK-37857) Add a DSV2 sink implementation to tests which can collect data Gabor Somogyi (Jira)
• [jira] [Closed] (FLINK-37857) Add a DSV2 sink implementation to tests which can collect data Gabor Somogyi (Jira)
• [jira] [Commented] (FLINK-37857) Add a DSV2 sink implementation to tests which can collect data Gabor Somogyi (Jira)
• [PR] Model physical [flink] via GitHub
  • Re: [PR] Model physical [flink] via GitHub
• [jira] [Assigned] (FLINK-37859) [umbrella] FLIP-516: Streaming Multi-Way Join Optimization dalongliu (Jira)
• [jira] [Commented] (FLINK-36953) FLIP-497: Early Fire Support for Flink SQL Interval Join dalongliu (Jira)
  • [jira] [Commented] (FLINK-36953) FLIP-497: Early Fire Support for Flink SQL Interval Join Weiqing Yang (Jira)
• [jira] [Commented] (FLINK-37723) FLIP-498: AsyncTableFunction for async table function support dalongliu (Jira)
• [jira] [Commented] (FLINK-37861) FLIP-520: Simplify StructuredType handling dalongliu (Jira)
• [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow for 1.19 [flink] via GitHub
  • Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow for 1.19 [flink] via GitHub
  • Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow for 1.19 [flink] via GitHub
  • Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow for 1.19 [flink] via GitHub
  • Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow for 1.19 [flink] via GitHub
  • Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow for 1.19 [flink] via GitHub
• [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow for 1.20 [flink] via GitHub
  • Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow for 1.20 [flink] via GitHub
  • Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow for 1.20 [flink] via GitHub
  • Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow for 1.20 [flink] via GitHub
  • Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow for 1.20 [flink] via GitHub
• [jira] [Assigned] (FLINK-37812) Fix broken links to Apache Avro in doc and code Xintong Song (Jira)
• [jira] [Assigned] (FLINK-37863) DynamicKafkaSource support in PyFlink Shuyi Chen (Jira)
• [jira] [Updated] (FLINK-37865) Add documentation for AsyncTableFunction ASF GitHub Bot (Jira)
• [PR] [FLINK-37865] Adds documentation for AsyncTableFunction [flink] via GitHub
  • Re: [PR] [FLINK-37865] Adds documentation for AsyncTableFunction [flink] via GitHub
  • Re: [PR] [FLINK-37865] Adds documentation for AsyncTableFunction [flink] via GitHub
  • Re: [PR] [FLINK-37865] Adds documentation for AsyncTableFunction [flink] via GitHub
  • Re: [PR] [FLINK-37865] Adds documentation for AsyncTableFunction [flink] via GitHub
  • Re: [PR] [FLINK-37865] Adds documentation for AsyncTableFunction [flink] via GitHub
  • Re: [PR] [FLINK-37865] Adds documentation for AsyncTableFunction [flink] via GitHub
  • Re: [PR] [FLINK-37865] Adds documentation for AsyncTableFunction [flink] via GitHub
  • Re: [PR] [FLINK-37865] Adds documentation for AsyncTableFunction [flink] via GitHub
  • Re: [PR] [FLINK-37865] Adds documentation for AsyncTableFunction [flink] via GitHub
  • Re: [PR] [FLINK-37865] Adds documentation for AsyncTableFunction [flink] via GitHub
  • Re: [PR] [FLINK-37865] Adds documentation for AsyncTableFunction [flink] via GitHub
  • Re: [PR] [FLINK-37865] Adds documentation for AsyncTableFunction [flink] via GitHub
  • Re: [PR] [FLINK-37865] Adds documentation for AsyncTableFunction [flink] via GitHub
• [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
• [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
• [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
• [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
• [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)

• Earlier messages