issues  

Messages by Date

• 2025/05/11 Re: [PR] [FLINK-37767][doc] Update reference branch/version for es connector [flink] via GitHub
• 2025/05/11 Re: [PR] [FLINK-37640][table-planner] Fix timestamp_ltz is converted timestamp in scan reuse [flink] via GitHub
• 2025/05/11 Re: [PR] [FLINK-36876] Add proxy for restClient [flink-kubernetes-operator] via GitHub
• 2025/05/11 Re: [PR] [FLINK-37640][table-planner] Fix timestamp_ltz is converted timestamp in scan reuse [flink] via GitHub
• 2025/05/11 Re: [PR] [hotfix][state] Remove duplicate comparing about intersect group range. [flink] via GitHub
• 2025/05/11 Re: [PR] [FLINK-37128][pipeline-connector/mysql] Binlog reader skip `shouldEmit` filter when snapshot reader skip backfill [flink-cdc] via GitHub
• 2025/05/11 Re: [PR] [FLINK-37128][pipeline-connector/mysql] Binlog reader skip `shouldEmit` filter when snapshot reader skip backfill [flink-cdc] via GitHub
• 2025/05/11 Re: [PR] [FLINK-35019] support convert show create model sql to operation [flink] via GitHub
• 2025/05/11 Re: [PR] [FLINK-35019] support convert show create model sql to operation [flink] via GitHub
• 2025/05/11 Re: [PR] [FLINK-37640][table-planner] Fix timestamp_ltz is converted timestamp in scan reuse [flink] via GitHub
• 2025/05/11 [jira] [Resolved] (FLINK-37552) Made StateMetaInfo consistent for ForStKeyeStateBackend and ForStSyncKeyeStateBackend. Yanfei Lei (Jira)
• 2025/05/11 [jira] [Assigned] (FLINK-37552) Made StateMetaInfo consistent for ForStKeyeStateBackend and ForStSyncKeyeStateBackend. Yanfei Lei (Jira)
• 2025/05/11 [jira] [Assigned] (FLINK-37552) Made StateMetaInfo consistent for ForStKeyeStateBackend and ForStSyncKeyeStateBackend. Yanfei Lei (Jira)
• 2025/05/11 Re: [PR] [FLINK-37552] Support switching between ForStKeyedStatebackend and ForStSyncKeyedStatebackend [flink] via GitHub
• 2025/05/10 Re: [PR] [FLINK-26760][flink-csv] The new CSV source (file system source + CSV… [flink] via GitHub
• 2025/05/10 Re: [PR] [FLINK-36487] Remove deprecated method createTemporaryView StreamTableE… [flink] via GitHub
• 2025/05/10 Re: [PR] FLINK-36479 remove deprecated method Table getSchema as [flink] via GitHub
• 2025/05/10 Re: [PR] FLINK-36479 remove deprecated method Table getSchema as [flink] via GitHub
• 2025/05/10 Re: [PR] [FLINK-36487] Remove deprecated method createTemporaryView StreamTableE… [flink] via GitHub
• 2025/05/10 Re: [PR] [FLINK-26760][flink-csv] The new CSV source (file system source + CSV… [flink] via GitHub
• 2025/05/10 Re: [PR] [FLINK-33977][runtime] Adaptive scheduler may not minimize the number of TMs during downscaling [flink] via GitHub
• 2025/05/10 Re: [PR] [FLINK-33977][runtime] Adaptive scheduler may not minimize the number of TMs during downscaling [flink] via GitHub
• 2025/05/10 Re: [PR] [FLINK-33977][runtime] Adaptive scheduler may not minimize the number of TMs during downscaling [flink] via GitHub
• 2025/05/10 Re: [PR] [FLINK-33977][runtime] Adaptive scheduler may not minimize the number of TMs during downscaling [flink] via GitHub
• 2025/05/10 Re: [PR] [FLINK-33977][runtime] Adaptive scheduler may not minimize the number of TMs during downscaling [flink] via GitHub
• 2025/05/10 Re: [PR] [FLINK-33977][runtime] Adaptive scheduler may not minimize the number of TMs during downscaling [flink] via GitHub
• 2025/05/10 Re: [PR] [FLINK-33977][runtime] Adaptive scheduler may not minimize the number of TMs during downscaling [flink] via GitHub
• 2025/05/10 Re: [PR] Fix CVE-2022-25168 [flink] via GitHub
• 2025/05/10 [PR] Fix CVE-2022-25168 [flink] via GitHub
• 2025/05/09 Re: [PR] [FLINK-37184][connector/filesystem] Add ZStandard to supported standard decompressors [flink] via GitHub
• 2025/05/09 Re: [PR] [hotfix] [docs] Edit Docs link location [flink] via GitHub
• 2025/05/09 Re: [PR] Upgrade com.squareup.okio:okio [flink] via GitHub
• 2025/05/09 Re: [PR] [FLINK-34251][core] ClosureCleaner to include reference classes for non-serialization exception [flink] via GitHub
• 2025/05/09 Re: [PR] FLINK-25029: Hadoop Caller Context Setting in Flink [flink] via GitHub
• 2025/05/09 [jira] [Updated] (FLINK-37774) SQL Server CDC connector incorrectly handles special characters in database and table names ASF GitHub Bot (Jira)
• 2025/05/09 [PR] FLINK-37774: SQL Server CDC connector incorrectly handles special characters in database and table names [flink-cdc] via GitHub
• 2025/05/09 [jira] [Updated] (FLINK-37774) SQL Server CDC connector incorrectly handles special characters in database and table names Sergei Morozov (Jira)
• 2025/05/09 [jira] [Created] (FLINK-37774) SQL Server CDC connector incorrectly handles special characters in database and table names Sergei Morozov (Jira)
• 2025/05/09 Re: [PR] [WIP][table] Algin Calcite Rules. [flink] via GitHub
• 2025/05/09 [jira] [Updated] (FLINK-37773) Extra TMs are started when Jobmanger is OOM killed in some FlinkDeployment runs Nihar Rao (Jira)
• 2025/05/09 [jira] [Created] (FLINK-37773) Extra TMs are started when Jobmanger is OOM killed in some FlinkDeployment runs Nihar Rao (Jira)
• 2025/05/09 [PR] [FLINK-32609] Support Projection Pushdown [flink-connector-kafka] via GitHub
• 2025/05/09 Re: [PR] [FLINK-37730][Job Manager] Expose JM exception as K8s exceptions [flink-kubernetes-operator] via GitHub
• 2025/05/09 Re: [PR] [WIP][table] Algin Calcite Rules. [flink] via GitHub
• 2025/05/09 Re: [PR] Updated readme with stream-processing [flink] via GitHub
• 2025/05/09 Re: [PR] [FLINK-xxx][2/N] extend catalog schema reader to get model [flink] via GitHub
• 2025/05/09 Re: [PR] [BP-1.19][FLINK-35241][table]Support SQL FLOOR and CEIL functions with SECOND and MINUTE for TIMESTAMP_TLZ [flink] via GitHub
• 2025/05/09 [jira] [Updated] (FLINK-37721) Fix janino bug returning incorrect results ASF GitHub Bot (Jira)
• 2025/05/09 Re: [PR] [FLINK-37721] Fixes janino bug returning incorrect results [flink] via GitHub
• 2025/05/09 [jira] [Commented] (FLINK-34430) Akka frame size exceeded with many ByteStreamStateHandle being used Trystan (Jira)
• 2025/05/09 Re: [PR] [FLINK-33977][runtime] Adaptive scheduler may not minimize the number of TMs during downscaling [flink] via GitHub
• 2025/05/09 [jira] [Closed] (FLINK-37545) StackOverflowError when using MetricGroup in custom WatermarkStrategy Piotr Nowojski (Jira)
• 2025/05/09 Re: [PR] [runtime-web] chore: update Angular to v15 [flink] via GitHub
• 2025/05/09 Re: [PR] [FLINK-36675][table-planner] Always serialize dynamic options to exec json plan [flink] via GitHub
• 2025/05/09 Re: [PR] [BP-1.20][FLINK-35241][table]Support SQL FLOOR and CEIL functions with SECOND and MINUTE for TIMESTAMP_TLZ [flink] via GitHub
• 2025/05/09 Re: [PR] fix: class-loading-issue [flink] via GitHub
• 2025/05/09 Re: [PR] FLINK-36505 remove deprecated methods TableFunction [flink] via GitHub
• 2025/05/09 Re: [PR] [hotfix] [docs]Fix miss semicolon on SELECT & WHERE clause example sql [flink] via GitHub
• 2025/05/09 Re: [PR] [FLINK-33977][runtime] Adaptive scheduler may not minimize the number of TMs during downscaling [flink] via GitHub
• 2025/05/09 Re: [PR] [docs-zh]The description of creating a materialized table does not match the example code,The description states 1 hour, while the code states 10 minutes [flink] via GitHub
• 2025/05/09 Re: [PR] [FLINK-33977][runtime] Adaptive scheduler may not minimize the number of TMs during downscaling [flink] via GitHub
• 2025/05/09 Re: [PR] [hotfix][test] Remove redundant keywords and lines for ForStGeneralMultiGetOperationTest.java [flink] via GitHub
• 2025/05/09 Re: [PR] [hotfix] [docs]Fix miss semicolon on SELECT & WHERE clause example sql [flink] via GitHub
• 2025/05/09 Re: [PR] [FLINK-37768] ConstraintEnforcer not handling all constraints [flink] via GitHub
• 2025/05/09 [jira] [Commented] (FLINK-33977) Adaptive scheduler may not minimize the number of TMs during downscaling RocMarshal (Jira)
• 2025/05/09 [jira] [Updated] (FLINK-33977) Adaptive scheduler may not minimize the number of TMs during downscaling RocMarshal (Jira)
• 2025/05/09 [jira] [Commented] (FLINK-32609) Kafka table source supports projection push down Calico Shop (Jira)
• 2025/05/09 [jira] [Updated] (FLINK-32609) Kafka table source supports projection push down ASF GitHub Bot (Jira)
• 2025/05/09 Re: [PR] [FLIP-516][FLINK-37481] Add new multi way join operator [flink] via GitHub
• 2025/05/09 Re: [PR] [FLIP-516][FLINK-37481] Add new multi way join operator [flink] via GitHub
• 2025/05/09 Re: [PR] [FLINK-36679][runtime] Add a metric to track checkpoint _metadata size [flink] via GitHub
• 2025/05/09 Re: [PR] [hotfix][state] Remove duplicate comparing about intersect group range. [flink] via GitHub
• 2025/05/09 [PR] [hotfix][state] Remove duplicate comparing about intersect group range. [flink] via GitHub
• 2025/05/09 [jira] [Commented] (FLINK-36876) Operator Heap Memory Leak Gyula Fora (Jira)
• 2025/05/09 Re: [PR] [FLINK-36876] Support external eventLoopGroup for RestClient [flink] via GitHub
• 2025/05/09 Re: [PR] [FLINK-37552] Support switching between ForStKeyedStatebackend and ForStSyncKeyedStatebackend [flink] via GitHub
• 2025/05/09 Re: [PR] [FLINK-36925][table] Introduce SemiAntiJoinOperator in Join with Async State API [flink] via GitHub
• 2025/05/09 Re: [PR] Fix flaky tests in classes PartitionableSourceTest and PushPartitionIntoTableSourceScanRuleTest [flink] via GitHub
• 2025/05/09 [jira] [Commented] (FLINK-37747) GlobalCommitterOperator cannot commit after scaling writer/committer Arvid Heise (Jira)
• 2025/05/09 [jira] [Updated] (FLINK-37747) GlobalCommitterOperator cannot commit after scaling writer/committer Arvid Heise (Jira)
• 2025/05/09 Re: [PR] [FLINK-37768] ConstraintEnforcer not handling all constraints [flink] via GitHub
• 2025/05/09 Re: [PR] [FLINK-37771] Simplify getPartitionedState of AbstractKeyedStateBackend [flink] via GitHub
• 2025/05/09 Re: [PR] [FLINK-36679][runtime] Add a metric to track checkpoint _metadata size [flink] via GitHub
• 2025/05/09 Re: [PR] [FLINK-36498] [table] Remove deprecated method ResolvedCatalogBaseTablele#getSchema [flink] via GitHub
• 2025/05/09 [jira] [Commented] (FLINK-33183) Enable metadata columns in NduAnalyzer with retract if non-virtual Martijn Visser (Jira)
• 2025/05/09 Re: [PR] Event latency does not equal window triggering [flink] via GitHub
• 2025/05/09 Re: [PR] [FLINK-36808][table-planner] Fix LookupJoin bug when used with filterable table source [flink] via GitHub
• 2025/05/09 [jira] [Resolved] (FLINK-37674) Add generalized type information to SQL state connector Gabor Somogyi (Jira)
• 2025/05/09 [jira] [Closed] (FLINK-37674) Add generalized type information to SQL state connector Gabor Somogyi (Jira)
• 2025/05/09 Re: [PR] [FLINK-37674][state] Add generic type information handling for state SQL [flink] via GitHub
• 2025/05/09 Re: [PR] [FLINK-37640][table-planner] Fix timestamp_ltz is converted timestamp in scan reuse [flink] via GitHub
• 2025/05/09 [jira] [Commented] (FLINK-33977) Adaptive scheduler may not minimize the number of TMs during downscaling RocMarshal (Jira)
• 2025/05/09 Re: [PR] [FLINK-36769] support fury serializer for pyflink [flink] via GitHub
• 2025/05/09 Re: [PR] [FLINK-37545][metrics] Fix StackOverflowError when using MetricGroup in custom WatermarkStrategy (2.0) [flink] via GitHub
• 2025/05/09 Re: [PR] [runtime-web] chore: update Angular to v15 [flink] via GitHub
• 2025/05/09 Re: [PR] [FLINK-37545][metrics] Fix StackOverflowError when using MetricGroup in custom WatermarkStrategy (1.20) [flink] via GitHub
• 2025/05/08 Re: [PR] [FLINK-37730][Job Manager] Expose JM exception as K8s exceptions [flink-kubernetes-operator] via GitHub
• 2025/05/08 Re: [PR] Bump org.apache.avro:avro from 1.8.2 to 1.11.4 in /flink-connectors/flink-connector-hive [flink] via GitHub
• 2025/05/08 Re: [PR] Fix typo from MARCO to MACRO [flink] via GitHub
• 2025/05/08 Re: [PR] solve bash-java-utils.sh can't get "env.java.home" in "config.yaml" since 1.20 [flink] via GitHub
• 2025/05/08 Re: [PR] [FLINK-36925][table] Introduce SemiAntiJoinOperator in Join with Async State API [flink] via GitHub
• 2025/05/08 Re: [PR] Update flink-architecture.md [flink] via GitHub
• 2025/05/08 Re: [PR] [docs-zh]The description of creating a materialized table does not match the example code,The description states 1 hour, while the code states 10 minutes [flink] via GitHub
• 2025/05/08 Re: [PR] [FLINK-36437][hive] Fix hive connector complie error in JDK11 [flink] via GitHub
• 2025/05/08 Re: [PR] [FLINK-12173][table] Optimize SELECT DISTINCT [flink] via GitHub
• 2025/05/08 Re: [PR] [FLINK-37020]Remove CHARACTER_FILTER.filterCharacters function when notify dimension values. [flink] via GitHub
• 2025/05/08 Re: [PR] [FLINK-36918][table] Introduce ProcTimeSortOperator in TemporalSort with Async State API [flink] via GitHub
• 2025/05/08 Re: [PR] [FLINK-36625] add lineage helper class for connector integration [flink] via GitHub
• 2025/05/08 Re: [PR] [DRAFT/WIP] [FLINK-25082] OverWindow in batch mode failed [flink] via GitHub
• 2025/05/08 Re: [PR] Bump org.apache.avro:avro from 1.8.2 to 1.11.4 in /flink-connectors/flink-connector-hive [flink] via GitHub
• 2025/05/08 Re: [PR] FLINK-36540.[Runtime / Task] Add Support for Hadoop Caller Context when using Flink to operate hdfs. [flink] via GitHub
• 2025/05/08 Re: [PR] [FLINK-36456] [Runtime/Configuration] Improve Security in DatadogHttpReporterFactory by providing ENV alternative to retrieve API key [flink] via GitHub
• 2025/05/08 Re: [PR] [FLINK-36498] [table] Remove deprecated method ResolvedCatalogBaseTablele#getSchema [flink] via GitHub
• 2025/05/08 Re: [PR] Upgrade com.squareup.okio:okio [flink] via GitHub
• 2025/05/08 Re: [PR] [FLINK-36456] [Runtime/Configuration] Improve Security in DatadogHttpReporterFactory by providing ENV alternative to retrieve API key [flink] via GitHub
• 2025/05/08 Re: [PR] [hotfix] Fixing flaky tests in flink-table-planner /hints [flink] via GitHub
• 2025/05/08 Re: [PR] [BP-1.20][FLINK-35241][table]Support SQL FLOOR and CEIL functions with SECOND and MINUTE for TIMESTAMP_TLZ [flink] via GitHub
• 2025/05/08 Re: [PR] Test [flink] via GitHub
• 2025/05/08 Re: [PR] [FLINK-36918][table] Introduce ProcTimeSortOperator in TemporalSort with Async State API [flink] via GitHub
• 2025/05/08 Re: [PR] Update flink-architecture.md [flink] via GitHub
• 2025/05/08 Re: [PR] [FLINK-35745] add documentation for flink lineage [flink] via GitHub
• 2025/05/08 Re: [PR] [FLINK-12173][table] Optimize SELECT DISTINCT [flink] via GitHub
• 2025/05/08 Re: [PR] [FLINK-37020]Remove CHARACTER_FILTER.filterCharacters function when notify dimension values. [flink] via GitHub
• 2025/05/08 Re: [PR] Bump org.apache.avro:avro from 1.8.2 to 1.11.4 in /flink-connectors/flink-connector-hive [flink] via GitHub
• 2025/05/08 Re: [PR] solve bash-java-utils.sh can't get "env.java.home" in "config.yaml" since 1.20 [flink] via GitHub
• 2025/05/08 Re: [PR] Update maxwell.md [flink] via GitHub
• 2025/05/08 Re: [PR] Update maxwell.md [flink] via GitHub
• 2025/05/08 Re: [PR] [hotfix] [docs] Update table environment variable name in common.md [flink] via GitHub
• 2025/05/08 Re: [PR] [FLINK-36625] add lineage helper class for connector integration [flink] via GitHub
• 2025/05/08 Re: [PR] [hotfix] [docs] Update table environment variable name in common.md [flink] via GitHub
• 2025/05/08 Re: [PR] fix: class-loading-issue [flink] via GitHub
• 2025/05/08 Re: [PR] Fix typo from MARCO to MACRO [flink] via GitHub
• 2025/05/08 Re: [PR] [BP-1.19][FLINK-35241][table]Support SQL FLOOR and CEIL functions with SECOND and MINUTE for TIMESTAMP_TLZ [flink] via GitHub
• 2025/05/08 Re: [PR] Fix flaky tests in classes PartitionableSourceTest and PushPartitionIntoTableSourceScanRuleTest [flink] via GitHub
• 2025/05/08 Re: [PR] Fixed Flaky test in org.apache.flink.table.planner.plan.hints.stream.StateTtlHintTest#testStateTtlHintWithJoinHint [flink] via GitHub
• 2025/05/08 Re: [PR] [FLINK-35745] add documentation for flink lineage [flink] via GitHub
• 2025/05/08 Re: [PR] [FLINK-36769] support fury serializer for pyflink [flink] via GitHub
• 2025/05/08 Re: [PR] Test [flink] via GitHub
• 2025/05/08 Re: [PR] Event latency does not equal window triggering [flink] via GitHub
• 2025/05/08 Re: [PR] [DRAFT/WIP] [FLINK-25082] OverWindow in batch mode failed [flink] via GitHub
• 2025/05/08 Re: [PR] [FLINK-36675][table-planner] Always serialize dynamic options to exec json plan [flink] via GitHub
• 2025/05/08 Re: [PR] FLINK-36505 remove deprecated methods TableFunction [flink] via GitHub
• 2025/05/08 Re: [PR] FLINK-36540.[Runtime / Task] Add Support for Hadoop Caller Context when using Flink to operate hdfs. [flink] via GitHub
• 2025/05/08 Re: [PR] [hotfix] Fixing flaky tests in flink-table-planner /hints [flink] via GitHub
• 2025/05/08 Re: [PR] [FLINK-36437][hive] Fix hive connector complie error in JDK11 [flink] via GitHub
• 2025/05/08 Re: [PR] Updated readme with stream-processing [flink] via GitHub
• 2025/05/08 Re: [PR] Fixed Flaky test in org.apache.flink.table.planner.plan.hints.stream.StateTtlHintTest#testStateTtlHintWithJoinHint [flink] via GitHub
• 2025/05/08 Re: [PR] [FLINK-37730][Job Manager] Expose JM exception as K8s exceptions [flink-kubernetes-operator] via GitHub
• 2025/05/08 [jira] [Commented] (FLINK-33977) Adaptive scheduler may not minimize the number of TMs during downscaling Ferenc Csaky (Jira)
• 2025/05/08 Re: [PR] [FLINK-37730][Job Manager] Expose JM exception as K8s exceptions [flink-kubernetes-operator] via GitHub
• 2025/05/08 [jira] [Updated] (FLINK-33977) Adaptive scheduler may not minimize the number of TMs during downscaling Ferenc Csaky (Jira)
• 2025/05/08 Re: [PR] [FLINK-37730][Job Manager] Expose JM exception as K8s exceptions [flink-kubernetes-operator] via GitHub
• 2025/05/08 Re: [PR] [FLINK-37730][Job Manager] Expose JM exception as K8s exceptions [flink-kubernetes-operator] via GitHub
• 2025/05/08 Re: [PR] [FLINK-37730][Job Manager] Expose JM exception as K8s exceptions [flink-kubernetes-operator] via GitHub
• 2025/05/08 Re: [PR] [FLINK-37730][Job Manager] Expose JM exception as K8s exceptions [flink-kubernetes-operator] via GitHub
• 2025/05/08 Re: [PR] [FLINK-37552] Support switching between ForStKeyedStatebackend and ForStSyncKeyedStatebackend [flink] via GitHub
• 2025/05/08 [jira] [Commented] (FLINK-33977) Adaptive scheduler may not minimize the number of TMs during downscaling RocMarshal (Jira)
• 2025/05/08 Re: [PR] [FLINK-xxx][2/N] extend catalog schema reader to get model [flink] via GitHub
• 2025/05/08 Re: [PR] [Docs] Update mysql-to-doris.md, add scan.startup.mode config to make demo run more smoothly [flink-cdc] via GitHub
• 2025/05/08 [PR] Model schema client [flink] via GitHub
• 2025/05/08 Re: [PR] [FLINK-37545][metrics] Fix StackOverflowError when using MetricGroup in custom WatermarkStrategy [flink] via GitHub
• 2025/05/08 [jira] [Commented] (FLINK-28693) Codegen failed if the watermark is defined on a columnByExpression Jira
• 2025/05/08 Re: [PR] [FLINK-37730][Job Manager] Expose JM exception as K8s exceptions [flink-kubernetes-operator] via GitHub
• 2025/05/08 [PR] [FLINK-37545][metrics] Fix StackOverflowError when using MetricGroup in custom WatermarkStrategy (2.0) [flink] via GitHub
• 2025/05/08 [PR] [FLINK-37545][metrics] Fix StackOverflowError when using MetricGroup in custom WatermarkStrategy [flink] via GitHub
• 2025/05/08 Re: [PR] [FLINK-37545][metrics] Fix StackOverflowError when using MetricGroup in custom WatermarkStrategy (2.0) [flink] via GitHub
• 2025/05/08 Re: [PR] [FLINK-37545][metrics] Fix StackOverflowError when using MetricGroup in custom WatermarkStrategy (2.0) [flink] via GitHub
• 2025/05/08 [jira] [Commented] (FLINK-37545) StackOverflowError when using MetricGroup in custom WatermarkStrategy Piotr Nowojski (Jira)
• 2025/05/08 [PR] [FLINK-37545][metrics] Fix StackOverflowError when using MetricGroup in custom WatermarkStrategy [flink] via GitHub
• 2025/05/08 Re: [PR] [FLINK-37545][metrics] Fix StackOverflowError when using MetricGroup in custom WatermarkStrategy [flink] via GitHub
• 2025/05/08 Re: [PR] [FLIP-516][FLINK-37481] Add new multi way join operator [flink] via GitHub
• 2025/05/08 [PR] [FLINK-37768] ConstraintEnforcer not handling all constraints [flink] via GitHub
• 2025/05/08 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
• 2025/05/08 Re: [PR] [FLINK-37768] ConstraintEnforcer not handling all constraints [flink] via GitHub
• 2025/05/08 [jira] [Closed] (FLINK-28897) Fail to use udf in added jar when enabling checkpoint Ferenc Csaky (Jira)
• 2025/05/08 [jira] [Assigned] (FLINK-37545) StackOverflowError when using MetricGroup in custom WatermarkStrategy Piotr Nowojski (Jira)
• 2025/05/08 [jira] [Updated] (FLINK-37768) ConstraintEnforcer not handling all constraints ASF GitHub Bot (Jira)
• 2025/05/08 Re: [PR] [FLINK-37545][metrics] Fix StackOverflowError when using MetricGroup in custom WatermarkStrategy [flink] via GitHub
• 2025/05/08 [jira] [Updated] (FLINK-37545) StackOverflowError when using MetricGroup in custom WatermarkStrategy ASF GitHub Bot (Jira)
• 2025/05/08 Re: [PR] [FLIP-516][FLINK-37481] Add new multi way join operator [flink] via GitHub
• 2025/05/08 Re: [PR] [FLIP-516][FLINK-37481] Add new multi way join operator [flink] via GitHub
• 2025/05/08 [jira] [Comment Edited] (FLINK-34016) Janino compile failed when watermark with column by udf Jira
• 2025/05/08 Re: [PR] [FLINK-37771] Simplify getPartitionedState of AbstractKeyedStateBackend [flink] via GitHub
• 2025/05/08 [PR] [FLINK-37772] Add AWS Connectors v5.1.0 [flink-web] via GitHub
• 2025/05/08 [jira] [Updated] (FLINK-37772) Release flink-connector-aws v5.1.0 ASF GitHub Bot (Jira)
• 2025/05/08 [PR] [FLINK-37772] Bump connector version to 5.1.0 [flink-connector-aws] via GitHub
• 2025/05/08 [jira] [Created] (FLINK-37772) Release flink-connector-aws v5.1.0 Daren Wong (Jira)
• 2025/05/08 [jira] [Updated] (FLINK-37771) Simplify getPartitionedState of AbstractKeyedStateBackend ASF GitHub Bot (Jira)
• 2025/05/08 [PR] [FLINK-37771] Simplify getPartitionedState of AbstractKeyedStateBackend [flink] via GitHub
• 2025/05/08 [jira] [Created] (FLINK-37771) Simplify getPartitionedState of AbstractKeyedStateBackend Jiaan Geng (Jira)
• 2025/05/08 [jira] [Comment Edited] (FLINK-28693) Codegen failed if the watermark is defined on a columnByExpression Jira
• 2025/05/08 [jira] [Commented] (FLINK-34016) Janino compile failed when watermark with column by udf Jira
• 2025/05/08 Re: [PR] [FLINK-33388][runtime] Support tasks balancing at TM level for Default Scheduler [flink] via GitHub
• 2025/05/08 [jira] [Created] (FLINK-37770) FLIP-518: Introduce a community review process david radley (Jira)
• 2025/05/08 Re: [PR] [FLINK-37730][Job Manager] Expose JM exception as K8s exceptions [flink-kubernetes-operator] via GitHub
• 2025/05/08 Re: [PR] [FLINK-33388][runtime] Support tasks balancing at TM level for Default Scheduler [flink] via GitHub
• 2025/05/08 Re: [PR] [FLINK-37730][Job Manager] Expose JM exception as K8s exceptions [flink-kubernetes-operator] via GitHub
• 2025/05/08 Re: [PR] [FLINK-37730][Job Manager] Expose JM exception as K8s exceptions [flink-kubernetes-operator] via GitHub
• 2025/05/08 Re: [PR] [FLINK-37674][state] Add generic type information handling for state SQL [flink] via GitHub
• 2025/05/07 Re: [PR] [hotfix] [API/DataStream]: Ensure the proper triggering functionality of ContinuousProcessingTimeTrigger [flink] via GitHub

• Earlier messages
• Later messages