issues  

Messages by Thread

• • Re: [PR] [FLINK-35093][postgres] Add COMMITTED_OFFSET startup mode for Postgres CDC to resume from existing replication slot [flink-cdc] via GitHub
  • Re: [PR] [FLINK-35093][postgres] Add COMMITTED_OFFSET startup mode for Postgres CDC to resume from existing replication slot [flink-cdc] via GitHub
  • Re: [PR] [FLINK-35093][postgres] Add COMMITTED_OFFSET startup mode for Postgres CDC to resume from existing replication slot [flink-cdc] via GitHub
  • Re: [PR] [FLINK-35093][postgres] Add COMMITTED_OFFSET startup mode for Postgres CDC to resume from existing replication slot [flink-cdc] via GitHub
  • Re: [PR] [FLINK-35093][postgres] Add COMMITTED_OFFSET startup mode for Postgres CDC to resume from existing replication slot [flink-cdc] via GitHub
  • Re: [PR] [FLINK-35093][postgres] Add COMMITTED_OFFSET startup mode for Postgres CDC to resume from existing replication slot [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-37684) ClassCastException: cannot assign instance of java.lang.invoke.SerializedLambda to field org.apache.flink.streaming.runtime.partitioner.KeyGroupStreamPartitioner.keySelector Youjun Yuan (Jira)
• [jira] [Created] (FLINK-37684) ClassCastException: cannot assign instance of java.lang.invoke.SerializedLambda to field org.apache.flink.streaming.runtime.partitioner.KeyGroupStreamPartitioner.keySelector Youjun Yuan (Jira)
• [jira] [Updated] (FLINK-37683) [Connector][AWS] SSO credentials fail because of shaded dependencies missing Ryan Despain (Jira)
  • [jira] [Updated] (FLINK-37683) [Connector][AWS] SSO credentials fail because of shaded dependencies missing ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-37683) [Connector][AWS] SSO credentials fail because of shaded dependencies missing Ryan Despain (Jira)
• [jira] [Commented] (FLINK-36808) UNION ALL after lookup join produces unexpected results Muhammet Orazov (Jira)
  • [jira] [Commented] (FLINK-36808) UNION ALL after lookup join produces unexpected results Qingsheng Ren (Jira)
• [jira] [Commented] (FLINK-37670) Watermark alignment can deadlock job if there are no more splits to be assigned Piotr Nowojski (Jira)
  • [jira] [Commented] (FLINK-37670) Watermark alignment can deadlock job if there are no more splits to be assigned Piotr Nowojski (Jira)
• [jira] [Resolved] (FLINK-36947) Rate limiting the GetRecord call frequency Hong Liang Teoh (Jira)
• [PR] [release] Update `elastic.yml` for 3.1.0 release [flink-connector-elasticsearch] via GitHub
  • Re: [PR] [FLINK-37675] Update `elastic.yml` for 3.1.0 release [flink-connector-elasticsearch] via GitHub
• [PR] [FLINK-37682]: Upgrade Jackson Lib to Address CVE-2023-35116 [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-37682]: Upgrade Jackson Lib to Address CVE-2023-35116 [flink-kubernetes-operator] via GitHub
• Re: [PR] [FLINK-36988][table] Migrate LogicalCorrelateToJoinFromTemporalTableF… [flink] via GitHub
• [jira] [Updated] (FLINK-37669) [HELM] Add Helm chart unit tests to flink kubernetes operator ASF GitHub Bot (Jira)
• [jira] [Assigned] (FLINK-37298) Custom Batch Handling in AsyncSink Hong Liang Teoh (Jira)
• [jira] [Created] (FLINK-37682) Upgrade Jackson Lib to Address CVE-2023-35116 Atul Sharma (Jira)
• [jira] [Resolved] (FLINK-37675) Update elastic.yml for 3.1.0 release Weijie Guo (Jira)
• [jira] [Created] (FLINK-37674) Add generalized type information to SQL state connector Gabor Somogyi (Jira)
• [jira] [Comment Edited] (FLINK-37658) Improve the Datagen connector documentation david radley (Jira)
• [PR] [FLINK-37672] Bump protobuf-maven-plugin [flink] via GitHub
  • Re: [PR] [FLINK-37672] Bump protobuf-maven-plugin [flink] via GitHub
• [jira] [Updated] (FLINK-37672) Bump protobuf-maven-plugin from 0.5.1 to 0.6.1 ASF GitHub Bot (Jira)
• [PR] [hotfix][build] Update CI to support Flink 2.0 [flink-connector-aws] via GitHub
  • Re: [PR] [hotfix][build] Update CI to support Flink 2.0 [flink-connector-aws] via GitHub
• [PR] [hotfix][build] Update Python CI Java version to fix CI [flink-connector-aws] via GitHub
  • Re: [PR] [hotfix][build] Update Python CI Java version to fix CI [flink-connector-aws] via GitHub
• [jira] [Assigned] (FLINK-36947) Rate limiting the GetRecord call frequency Hong Liang Teoh (Jira)
• [jira] [Resolved] (FLINK-36939) High CPU Utilization with Flink Kinesis EFO Consumer Hong Liang Teoh (Jira)
• [jira] [Commented] (FLINK-36947) Rate limiting the GetRecord call frequency Hong Liang Teoh (Jira)
  • [jira] [Commented] (FLINK-36947) Rate limiting the GetRecord call frequency Darshan Siby (Jira)
• [jira] [Updated] (FLINK-37682) Upgrade Jackson Lib to Address CVE-2023-35116 ASF GitHub Bot (Jira)
• Re: [PR] [FLINK-37504] Handle TLS Certificate Renewal [flink] via GitHub
  • Re: [PR] [FLINK-37504] Handle TLS Certificate Renewal [flink] via GitHub
• [PR] [FLINK-37521][table] Implement Proc/RowTimeIntervalJoin with async state [flink] via GitHub
  • Re: [PR] [FLINK-37521][table] Implement Proc/RowTimeIntervalJoin with async state [flink] via GitHub
  • Re: [PR] [FLINK-37521][table] Implement Proc/RowTimeIntervalJoin with async state [flink] via GitHub
• [jira] [Commented] (FLINK-37298) Custom Batch Handling in AsyncSink Hong Liang Teoh (Jira)
• [jira] [Resolved] (FLINK-37298) Custom Batch Handling in AsyncSink Hong Liang Teoh (Jira)
• [jira] [Created] (FLINK-37677) [cdc-connector] Sink support skip create table event JunboWang (Jira)
• [PR] [hotfix] Remove unnecessary method overloading for method invoke [flink] via GitHub
  • Re: [PR] [hotfix] Remove unnecessary method override for method invoke [flink] via GitHub
  • Re: [PR] [hotfix] Remove unnecessary method override for method invoke [flink] via GitHub
• [jira] [Assigned] (FLINK-37608) File sink supports to close buckets in parallel when snapshot Hangxiang Yu (Jira)
• [jira] [Updated] (FLINK-37608) File sink supports to close buckets in parallel when snapshot Hangxiang Yu (Jira)
  • [jira] [Updated] (FLINK-37608) File sink supports to close buckets in parallel when snapshot ASF GitHub Bot (Jira)
• [jira] [Assigned] (FLINK-18590) Support json array explode to multi messages Hangxiang Yu (Jira)
• [jira] [Commented] (FLINK-18590) Support json array explode to multi messages Hongjia Liang (Jira)
  • [jira] [Commented] (FLINK-18590) Support json array explode to multi messages Hangxiang Yu (Jira)
  • [jira] [Commented] (FLINK-18590) Support json array explode to multi messages Xuyang Zhong (Jira)
• [jira] [Created] (FLINK-37680) Add subclass cache for PojoSerializer Zhanghao Chen (Jira)
• Re: [PR] [FLINK-36746] Fix the deadlock bug when initializing SerializedThrowable object. [flink] via GitHub
• Re: [PR] [FLINK-33449][table]Support array_contains_seq function [flink] via GitHub
  • Re: [PR] [FLINK-33449][table]Support array_contains_seq function [flink] via GitHub
• [jira] [Created] (FLINK-37681) Add benchmark for subclass seder with PojoSerializer in Flink benchmark Zhanghao Chen (Jira)
• [PR] [FLINK-37680][serializer] Add subclass cache for PojoSerializer [flink] via GitHub
  • Re: [PR] [FLINK-37680][serializer] Add subclass cache for PojoSerializer [flink] via GitHub
  • Re: [PR] [FLINK-37680][serializer] Add subclass cache for PojoSerializer [flink] via GitHub
  • Re: [PR] [FLINK-37680][serializer] Add subclass cache for PojoSerializer [flink] via GitHub
  • Re: [PR] [FLINK-37680][serializer] Add subclass cache for PojoSerializer [flink] via GitHub
  • Re: [PR] [FLINK-37680][serializer] Add subclass cache for PojoSerializer [flink] via GitHub
  • Re: [PR] [FLINK-37680][serializer] Add subclass cache for PojoSerializer [flink] via GitHub
• [jira] [Updated] (FLINK-37680) Add subclass cache for PojoSerializer Zhanghao Chen (Jira)
  • [jira] [Updated] (FLINK-37680) Add subclass cache for PojoSerializer ASF GitHub Bot (Jira)
• [jira] [Assigned] (FLINK-37676) Add a cache for TableId in Selector to improve performance Leonard Xu (Jira)
  • [jira] [Assigned] (FLINK-37676) Add a cache for TableId in Selector to improve performance Yanquan Lv (Jira)
• [jira] [Created] (FLINK-37679) Improve the performance of Flink serialization Zhanghao Chen (Jira)
• [jira] [Created] (FLINK-37678) suggest improve doris connector version tongyp (Jira)
• [jira] [Updated] (FLINK-37676) Add a cache for TableId in Selector to improve performance Yanquan Lv (Jira)
  • [jira] [Updated] (FLINK-37676) Add a cache for TableId in Selector to improve performance ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-37676) Add a cache for TableId in Selector to improve performance Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-37675) Update elastic.yml for 3.1.0 release Weijie Guo (Jira)
  • [jira] [Updated] (FLINK-37675) Update elastic.yml for 3.1.0 release ASF GitHub Bot (Jira)
• [jira] [Closed] (FLINK-37638) Avoid duplicate call on getEffectiveConfiguration Ferenc Csaky (Jira)
• [jira] [Updated] (FLINK-37100) Fix test_netty_shuffle_memory_control.sh with Netty4 RPC Ruan Hang (Jira)
• [jira] [Updated] (FLINK-37108) Source/Sink test suites test invalid recovery Ruan Hang (Jira)
• [PR] [FLINK-36670][core] Optimize port range out-of-bounds exception log [flink] via GitHub
  • Re: [PR] [FLINK-36670][core] Optimize port range out-of-bounds exception log [flink] via GitHub
  • Re: [PR] [FLINK-36670][core] Optimize port range out-of-bounds exception log [flink] via GitHub
  • Re: [PR] [FLINK-36670][core] Optimize port range out-of-bounds exception log [flink] via GitHub
• Re: [PR] [FLINK-37315][table-planner] Improve SelectivityEstimator#estimateEquals for columns in VARCHAR type [flink] via GitHub
• [jira] [Assigned] (FLINK-37636) Weekly CI failure Weijie Guo (Jira)
• [jira] [Resolved] (FLINK-37636) Weekly CI failure Weijie Guo (Jira)
• Re: [PR] [FLINK-36581][cli] Allow passing Flink configuration by yaml job file [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36581][cli] Allow passing Flink configuration by yaml job file [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36581][cli] Allow passing Flink configuration by yaml job file [flink-cdc] via GitHub
• [jira] [Created] (FLINK-37675) Update elastic.yml for 3.1.0 release Weijie Guo (Jira)
• Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
  • Re: [PR] [FLINK-37543][table-planner] Support sink reuse in batch mode [flink] via GitHub
• Re: [PR] [FLINK-37128][pipeline-connector/mysql] Binlog reader skip `shouldEmit` filter when snapshot reader skip backfill [flink-cdc] via GitHub
• [jira] [Commented] (FLINK-37623) Async state support for `process()` in Datastream API Yanfei Lei (Jira)
• [jira] [Commented] (FLINK-34779) look forward to adding dameng（dm8） connectors Enyuan Zhao (Jira)
• [PR] [FLINK-37605][runtime] Infer checkpoint id on endInput in sink [1.20] [flink] via GitHub
  • Re: [PR] [FLINK-37605][runtime] Infer checkpoint id on endInput in sink [1.20] [flink] via GitHub
  • Re: [PR] [FLINK-37605][runtime] Infer checkpoint id on endInput in sink [1.20] [flink] via GitHub
• Re: [PR] [FLINK-36165][source-connector/mysql] Support capturing snapshot data with conditions [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36165][source-connector/mysql] Support capturing snapshot data with conditions [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36165][source-connector/mysql] Support capturing snapshot data with conditions [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36165][source-connector/mysql] Support capturing snapshot data with conditions [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36165][source-connector/mysql] Support capturing snapshot data with conditions [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36165][source-connector/mysql] Support capturing snapshot data with conditions [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36165][source-connector/mysql] Support capturing snapshot data with conditions [flink-cdc] via GitHub
• [jira] [Commented] (FLINK-37673) The transformation of table metadata should only be effective for the first matching rule MOBIN (Jira)
  • [jira] [Commented] (FLINK-37673) The transformation of table metadata should only be effective for the first matching rule Yanquan Lv (Jira)
  • [jira] [Commented] (FLINK-37673) The transformation of table metadata should only be effective for the first matching rule Yanquan Lv (Jira)
  • [jira] [Commented] (FLINK-37673) The transformation of table metadata should only be effective for the first matching rule Yanquan Lv (Jira)
• [jira] [Assigned] (FLINK-37674) Add generalized type information to SQL state connector Gabor Somogyi (Jira)
• [jira] [Updated] (FLINK-36536) Bump commons-text from 1.10.0 to 1.12.0 ASF GitHub Bot (Jira)
• [PR] [FLINK-36536] Bumped `commons-text` from 1.10.0 to 1.12.0 [flink] via GitHub
  • Re: [PR] [FLINK-36536] Bumped `commons-text` from 1.10.0 to 1.12.0 [flink] via GitHub
• Re: [PR] [FLINK-36842] FlinkPipelineComposer allows injecting StreamExecutionEnvironment [flink-cdc] via GitHub
• Re: [PR] [FLINK-32418][formats-protobuf] Fix ClassNotFoundException when using protobuf in SQL-Client [flink] via GitHub
  • Re: [PR] [FLINK-32418][formats-protobuf] Fix ClassNotFoundException when using protobuf in SQL-Client [flink] via GitHub
  • Re: [PR] [FLINK-32418][formats-protobuf] Fix ClassNotFoundException when using protobuf in SQL-Client [flink] via GitHub
• [PR] [FLINK-37605][runtime] Infer checkpoint id on endInput in sink [1.19] [flink] via GitHub
  • Re: [PR] [FLINK-37605][runtime] Infer checkpoint id on endInput in sink [1.19] [flink] via GitHub
  • Re: [PR] [FLINK-37605][runtime] Infer checkpoint id on endInput in sink [1.19] [flink] via GitHub
• [PR] [FLINK-37605][runtime] Infer checkpoint id on endInput in sink [2.0] [flink] via GitHub
  • Re: [PR] [FLINK-37605][runtime] Infer checkpoint id on endInput in sink [2.0] [flink] via GitHub
  • Re: [PR] [FLINK-37605][runtime] Infer checkpoint id on endInput in sink [2.0] [flink] via GitHub
• [jira] [Created] (FLINK-37672) Bump protobuf-maven-plugin from 0.5.1 to 0.6.1 Siddharth R (Jira)
• Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] via GitHub
• Re: [PR] Add Kudu Connector 2.0.0 [flink-web] via GitHub
• [jira] [Created] (FLINK-37673) The transformation of table metadata should only be effective for the first matching rule Yanquan Lv (Jira)
• [jira] [Commented] (FLINK-37605) SinkWriter may incorrectly infer end of input during rescale Arvid Heise (Jira)
  • [jira] [Commented] (FLINK-37605) SinkWriter may incorrectly infer end of input during rescale Arvid Heise (Jira)
  • [jira] [Commented] (FLINK-37605) SinkWriter may incorrectly infer end of input during rescale Arvid Heise (Jira)
  • [jira] [Commented] (FLINK-37605) SinkWriter may incorrectly infer end of input during rescale Arvid Heise (Jira)
• Re: [PR] [FLINK-33139] Add Prometheus Sink Table API [flink-connector-prometheus] via GitHub
  • Re: [PR] [FLINK-33139] Add Prometheus Sink Table API [flink-connector-prometheus] via GitHub
  • Re: [PR] [FLINK-33139] Add Prometheus Sink Table API [flink-connector-prometheus] via GitHub
  • Re: [PR] [FLINK-33139] Add Prometheus Sink Table API [flink-connector-prometheus] via GitHub
  • Re: [PR] [FLINK-33139] Add Prometheus Sink Table API [flink-connector-prometheus] via GitHub
  • Re: [PR] [FLINK-33139] Add Prometheus Sink Table API [flink-connector-prometheus] via GitHub
  • Re: [PR] [FLINK-33139] Add Prometheus Sink Table API [flink-connector-prometheus] via GitHub
  • Re: [PR] [FLINK-33139] Add Prometheus Sink Table API [flink-connector-prometheus] via GitHub
  • Re: [PR] [FLINK-33139] Add Prometheus Sink Table API [flink-connector-prometheus] via GitHub
  • Re: [PR] [FLINK-33139] Add Prometheus Sink Table API [flink-connector-prometheus] via GitHub
  • Re: [PR] [FLINK-33139] Add Prometheus Sink Table API [flink-connector-prometheus] via GitHub
  • Re: [PR] [FLINK-33139] Add Prometheus Sink Table API [flink-connector-prometheus] via GitHub
  • Re: [PR] [FLINK-33139] Add Prometheus Sink Table API [flink-connector-prometheus] via GitHub
  • Re: [PR] [FLINK-33139] Add Prometheus Sink Table API [flink-connector-prometheus] via GitHub
  • Re: [PR] [FLINK-33139] Add Prometheus Sink Table API [flink-connector-prometheus] via GitHub
• [jira] [Commented] (FLINK-35744) Support flink 1.19 config.yaml format Diljeet Singh (Jira)
• Re: [PR] [FLINK-32097][Connectors/Kinesis] Implement support for Kinesis deaggregation [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-32097][Connectors/Kinesis] Implement support for Kinesis deaggregation [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-32097][Connectors/Kinesis] Implement support for Kinesis deaggregation [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-32097][Connectors/Kinesis] Implement support for Kinesis deaggregation [flink-connector-aws] via GitHub
• [PR] [FLINK-37658][docs] Improve the Datagen connector docs [flink] via GitHub
  • Re: [PR] [FLINK-37658][docs] Improve the Datagen connector docs [flink] via GitHub
  • Re: [PR] [FLINK-37658][docs] Improve the Datagen connector docs [flink] via GitHub
  • Re: [PR] [FLINK-37658][docs] Improve the Datagen connector docs [flink] via GitHub

• Earlier messages
• Later messages