issues  

Messages by Thread

• • Re: [PR] [hotfix] Fix Azure ChatModel class path in ResourceName. [flink-agents] via GitHub
• [PR] [hotfix] [docs] Fix broken flink-training links in hands-on section [flink] via GitHub
  • Re: [PR] [hotfix] [docs] Fix broken flink-training links in hands-on section [flink] via GitHub
  • Re: [PR] [hotfix] [docs] Fix broken flink-training links in hands-on section [flink] via GitHub
  • Re: [PR] [hotfix] [docs] Fix broken flink-training links in hands-on section [flink] via GitHub
  • Re: [PR] [hotfix] [docs] Fix broken flink-training links in hands-on section [flink] via GitHub
• [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
  • Re: [PR] Community blog March 2026 [flink-web] via GitHub
• [jira] [Commented] (FLINK-39191) Upgrade monaco-editor to 0.55.1 to get rid of DOMPurify CVEs Gyula Komlossi (Jira)
• [jira] [Updated] (FLINK-39191) Upgrade monaco-editor to 0.55.1 to get rid of DOMPurify CVEs ASF GitHub Bot (Jira)
• [PR] [FLINK-39191][runtime-web] Upgrade monaco-editor to 0.55.1 [flink] via GitHub
  • Re: [PR] [FLINK-39191][runtime-web] Upgrade monaco-editor to 0.55.1 [flink] via GitHub
  • Re: [PR] [FLINK-39191][runtime-web] Upgrade monaco-editor to 0.55.1 [flink] via GitHub
• [jira] [Updated] (FLINK-21309) Metrics of JobManager and TaskManager overwrite each other in pushgateway ASF GitHub Bot (Jira)
• [PR] [FLINK-21309][metrics] Add UUID as grouping key for prom pushgateway [flink] via GitHub
  • Re: [PR] [FLINK-21309][metrics] Add UUID as grouping key for prom pushgateway [flink] via GitHub
  • Re: [PR] [FLINK-21309][metrics] Add UUID as grouping key for prom pushgateway [flink] via GitHub
  • Re: [PR] [FLINK-21309][metrics] Add UUID as grouping key for prom pushgateway [flink] via GitHub
  • Re: [PR] [FLINK-21309][metrics] Add UUID as grouping key for prom pushgateway [flink] via GitHub
  • Re: [PR] [FLINK-21309][metrics] Add UUID as grouping key for prom pushgateway [flink] via GitHub
  • Re: [PR] [FLINK-21309][metrics] Add UUID as grouping key for prom pushgateway [flink] via GitHub
  • Re: [PR] [FLINK-21309][metrics] Add UUID as grouping key for prom pushgateway [flink] via GitHub
  • Re: [PR] [FLINK-21309][metrics] Add UUID as grouping key for prom pushgateway [flink] via GitHub
  • Re: [PR] [FLINK-21309][metrics] Add UUID as grouping key for prom pushgateway [flink] via GitHub
  • Re: [PR] [FLINK-21309][metrics] Add UUID as grouping key for prom pushgateway [flink] via GitHub
  • Re: [PR] [FLINK-21309][metrics] Add UUID as grouping key for prom pushgateway [flink] via GitHub
• [jira] [Resolved] (FLINK-39221) Add AGGREGATE_VALUES rule for constant folding of global aggregates Fabian Paul (Jira)
• [jira] [Updated] (FLINK-38920) create Table source and factory for DynamicKafkaSource in Flink Table API Ferenc Csaky (Jira)
• [jira] [Updated] (FLINK-39037) support query kafka cluster id as metadata in records of DynamicKafkaTableSource Ferenc Csaky (Jira)
• Re: [PR] [FLINK-38920] create Table source and factory for DynamicKafkaSource in Flink Table API [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-38920] create Table source and factory for DynamicKafkaSource in Flink Table API [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-38920] create Table source and factory for DynamicKafkaSource in Flink Table API [flink-connector-kafka] via GitHub
• [jira] [Updated] (FLINK-38999) License lineage files Ferenc Csaky (Jira)
• [jira] [Updated] (FLINK-39013) add E2E test for DynamicKafkaTableSource Ferenc Csaky (Jira)
• [jira] [Updated] (FLINK-38917) add doc of pyflink DynamicKafkaSource to flink-connector-kafka Ferenc Csaky (Jira)
• [jira] [Updated] (FLINK-38876) Support per-cluster offset in Dynamic Kafka Source Ferenc Csaky (Jira)
• [jira] [Updated] (FLINK-38471) flink-end-to-end-tests-common-kafka depends implicitely on kafka-sql-connector Ferenc Csaky (Jira)
• [jira] [Updated] (FLINK-37818) Kafka connector requires unqiue TransactionalIdPrefix even for non-EOS settings. Ferenc Csaky (Jira)
• [jira] [Updated] (FLINK-29245) [JUnit 5 Migration] Remove RetryRule Ferenc Csaky (Jira)
• [jira] [Updated] (FLINK-39012) Support global enumerator/dispatcher for dynamic Kafka source Ferenc Csaky (Jira)
• [jira] [Updated] (FLINK-37583) Upgrade Kafka Client version to 4.0.0 Ferenc Csaky (Jira)
• [jira] [Comment Edited] (FLINK-38704) Metrics reporter setup does not load Prometheus with correct configs/port Mukul Gupta (Jira)
  • [jira] [Comment Edited] (FLINK-38704) Metrics reporter setup does not load Prometheus with correct configs/port Mukul Gupta (Jira)
• [jira] [Commented] (FLINK-38704) Metrics reporter setup does not load Prometheus with correct configs/port Mukul Gupta (Jira)
• [jira] [Updated] (FLINK-38704) Metrics reporter setup does not load Prometheus with correct configs/port ASF GitHub Bot (Jira)
• [PR] [FLINK-38704][runtime] Convert config values to String [flink] via GitHub
  • Re: [PR] [FLINK-38704][runtime] Convert config values to String [flink] via GitHub
  • Re: [PR] [FLINK-38704][runtime] Convert config values to String [flink] via GitHub
  • Re: [PR] [FLINK-38704][runtime] Convert config values to String [flink] via GitHub
  • Re: [PR] [FLINK-38704][runtime] Convert config values to String [flink] via GitHub
  • Re: [PR] [FLINK-38704][runtime] Convert config values to String [flink] via GitHub
  • Re: [PR] [FLINK-38704][metrics] Fix MetricConfig.getString() to handle numeric values [flink] via GitHub
  • Re: [PR] [FLINK-38704][metrics] Fix MetricConfig.getString() to handle numeric values [flink] via GitHub
• Re: [PR] Maximum parallelism expansion can be used in MAXIMIZE_UTILISATION mode. [flink-kubernetes-operator] via GitHub
• [PR] feat: Flink 2.2 compatibility and dual-dist packaging [flink-cdc] via GitHub
  • Re: [PR] feat: Flink 2.2 compatibility and dual-dist packaging [flink-cdc] via GitHub
• [jira] [Resolved] (FLINK-39204) fluss yaml sink support add column at last Leonard Xu (Jira)
• [jira] [Updated] (FLINK-39221) Add AGGREGATE_VALUES rule for constant folding of global aggregates ASF GitHub Bot (Jira)
• [PR] [FLINK-39221][table] Add AGGREGATE_VALUES rule for constant folding o… [flink] via GitHub
  • Re: [PR] [FLINK-39221][table] Add AGGREGATE_VALUES rule for constant folding o… [flink] via GitHub
  • Re: [PR] [FLINK-39221][table] Add AGGREGATE_VALUES rule for constant folding o… [flink] via GitHub
  • Re: [PR] [FLINK-39221][table] Add AGGREGATE_VALUES rule for constant folding o… [flink] via GitHub
  • Re: [PR] [FLINK-39221][table] Add AGGREGATE_VALUES rule for constant folding o… [flink] via GitHub
• [jira] [Assigned] (FLINK-39220) Add tests for ConditionsUtils David Radley (Jira)
• [jira] [Created] (FLINK-39221) Add AGGREGATE_VALUES rule for constant folding of global aggregates Fabian Paul (Jira)
• [jira] [Assigned] (FLINK-39221) Add AGGREGATE_VALUES rule for constant folding of global aggregates Fabian Paul (Jira)
• [jira] [Updated] (FLINK-39220) Add tests for ConditionsUtils ASF GitHub Bot (Jira)
• Re: [PR] [FLINK-38959][pipeline-connector][postgres]Added support for schema change in the postgres pipeline connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38959][pipeline-connector][postgres]Added support for schema change in the postgres pipeline connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38959][pipeline-connector][postgres]Added support for schema change in the postgres pipeline connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38959][pipeline-connector][postgres]Added support for schema change in the postgres pipeline connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38959][pipeline-connector][postgres]Added support for schema change in the postgres pipeline connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38959][pipeline-connector][postgres]Added support for schema change in the postgres pipeline connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38959][pipeline-connector][postgres]Added support for schema change in the postgres pipeline connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38959][pipeline-connector][postgres]Added support for schema change in the postgres pipeline connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38959][pipeline-connector][postgres]Added support for schema change in the postgres pipeline connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38959][pipeline-connector][postgres]Added support for schema change in the postgres pipeline connector [flink-cdc] via GitHub
• [jira] [Commented] (FLINK-39210) Memory Leak Issue in Flink SQL with Multiple Temporal Joins Timo Walther (Jira)
• [PR] [FLINK-39152][pipeline-connector][Fluss]Fix FlussConfig Utils class is not in the correct directory and should have a private instance [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39152][pipeline-connector][Fluss]Fix FlussConfig Utils class is not in the correct directory and should have a private instance [flink-cdc] via GitHub
• [jira] [Assigned] (FLINK-39204) fluss yaml sink support add column at last Leonard Xu (Jira)
• [jira] [Updated] (FLINK-38975) Re-execute applications after HA recovery in session mode ASF GitHub Bot (Jira)
• [PR] [FLINK-38975][runtime] Support application recovery [flink] via GitHub
  • Re: [PR] [FLINK-38975][runtime] Support application recovery [flink] via GitHub
• [jira] [Updated] (FLINK-39204) fluss yaml sink support add column at last ASF GitHub Bot (Jira)
• [PR] [FLINK-39204] Fluss yaml sink support add column at last. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39204] Fluss yaml sink support add column at last. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39204] Fluss yaml sink support add column at last. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39204] Fluss yaml sink support add column at last. [flink-cdc] via GitHub
• [jira] [Commented] (FLINK-39220) Add tests for ConditionsUtils Harshit Gupta (Jira)
• [jira] [Created] (FLINK-39220) Add tests for ConditionsUtils Harshit Gupta (Jira)
• [jira] [Closed] (FLINK-39173) Support application-level blob storage Zhu Zhu (Jira)
• [PR] [MINOR] Update starrocks.md [flink-cdc] via GitHub
  • Re: [PR] [MINOR] Update starrocks.md [flink-cdc] via GitHub
  • Re: [PR] [MINOR] Update starrocks.md [flink-cdc] via GitHub
  • Re: [PR] [MINOR] Update starrocks.md [flink-cdc] via GitHub
  • Re: [PR] [MINOR] Update starrocks.md [flink-cdc] via GitHub
  • Re: [PR] [MINOR] Update starrocks.md [flink-cdc] via GitHub
  • Re: [PR] [MINOR] Update starrocks.md [flink-cdc] via GitHub
  • Re: [PR] [MINOR] Update starrocks.md [flink-cdc] via GitHub
  • Re: [PR] [MINOR] Update starrocks.md [flink-cdc] via GitHub
  • Re: [PR] [MINOR] Update starrocks.md [flink-cdc] via GitHub
• [jira] [Closed] (FLINK-39205) fluss yaml sink support array/map/row Hongshun Wang (Jira)
• [jira] [Commented] (FLINK-39122) Decimals with incorrect precision lead to null value in PTF Rion Williams (Jira)
• [jira] [Updated] (FLINK-39219) Support lineage extraction for DataStreamscan/sink providers Jaskaran Singh Kukreja (Jira)
  • [jira] [Updated] (FLINK-39219) Support lineage extraction for DataStreamscan/sink providers ASF GitHub Bot (Jira)
• [jira] [Commented] (FLINK-39219) Support lineage extraction for DataStreamscan/sink providers Jaskaran Singh Kukreja (Jira)
• [jira] [Created] (FLINK-39219) Support lineage extraction for DataStreamscan/sink providers Jaskaran Singh Kukreja (Jira)
• [jira] [Updated] (FLINK-38726) Bump Fluss version to 0.9.0-incubating Leonard Xu (Jira)
• [jira] [Resolved] (FLINK-38726) Bump Fluss version to 0.9.0-incubating Leonard Xu (Jira)
• Re: [PR] [FLINK-38726][fluss] Bump Fluss version to 0.9.0-incubating [flink-cdc] via GitHub
• [jira] [Closed] (FLINK-38974) Handle jobs in running applications during HA recovery Zhu Zhu (Jira)
• [jira] [Closed] (FLINK-39150) Join operator crashes jobs when using custom types or custom type serializers Zhu Zhu (Jira)
• Re: [PR] [FLINK-38980][table] Migrate RemoveRedundantLocalSortAggRule to java [flink] via GitHub
• [PR] Include Kafka record metadata in deserialization error message [flink-connector-kafka] via GitHub
  • Re: [PR] Include Kafka record metadata in deserialization error message [flink-connector-kafka] via GitHub
  • Re: [PR] Include Kafka record metadata in deserialization error message [flink-connector-kafka] via GitHub
• [jira] [Resolved] (FLINK-38981) Migrate BatchPhysicalSortMergeJoinRule Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-38981) Migrate BatchPhysicalSortMergeJoinRule Sergey Nuyanzin (Jira)
• [jira] [Assigned] (FLINK-38981) Migrate BatchPhysicalSortMergeJoinRule Sergey Nuyanzin (Jira)
• Re: [PR] [FLINK-38981][table] Migrate BatchPhysicalSortMergeJoinRule to java [flink] via GitHub
• [jira] [Resolved] (FLINK-39077) Calculation of table changes for MT with several non persisted columns might fail Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-39077) Calculation of table changes for MT with several non persisted columns might fail Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-39077) Calculation of table changes for MT with several non persisted columns might fail Sergey Nuyanzin (Jira)
  • [jira] [Updated] (FLINK-39077) Calculation of table changes for MT with several non persisted columns might fail Sergey Nuyanzin (Jira)
• [jira] [Resolved] (FLINK-17224) Precision of TIME type does not work correctly Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-17224) Precision of TIME type does not work correctly Sergey Nuyanzin (Jira)
• [jira] [Assigned] (FLINK-39218) Add CLI tool to manage lingering Kafka transactions Danny Cranmer (Jira)
• [jira] [Comment Edited] (FLINK-21309) Metrics of JobManager and TaskManager overwrite each other in pushgateway Qinghui Xu (Jira)
  • [jira] [Comment Edited] (FLINK-21309) Metrics of JobManager and TaskManager overwrite each other in pushgateway Qinghui Xu (Jira)
  • [jira] [Comment Edited] (FLINK-21309) Metrics of JobManager and TaskManager overwrite each other in pushgateway Qinghui Xu (Jira)
• [jira] [Commented] (FLINK-21309) Metrics of JobManager and TaskManager overwrite each other in pushgateway Qinghui Xu (Jira)
  • [jira] [Commented] (FLINK-21309) Metrics of JobManager and TaskManager overwrite each other in pushgateway Qinghui Xu (Jira)
• [jira] [Created] (FLINK-39218) Add CLI tool to manage lingering Kafka transactions Aleksandr Savonin (Jira)
• Re: [PR] [FLINK-39165] Prevent concurrent FlinkSessionJob / FlinkDeployment update [flink-kubernetes-operator] via GitHub
• [jira] [Closed] (FLINK-39182) Fix the flaky test class ExecutionGraphRestartTest Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-38850) Support PostgreSQL uuid type Yuepeng Pan (Jira)
• Re: [PR] [FLINK-38850] Support PostgreSQL uuid type [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-38850] Support PostgreSQL uuid type [flink-connector-jdbc] via GitHub
• [jira] [Resolved] (FLINK-39199) CREATE OR ALTER AMTERIALIZED TABLE doesn't support table options changes Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-39199) CREATE OR ALTER AMTERIALIZED TABLE doesn't support table options changes Sergey Nuyanzin (Jira)
• Re: [PR] [FLINK-38825] Introduce AsyncBatchFunction and AsyncBatchWaitOperator [flink] via GitHub
  • Re: [PR] [FLINK-38825] Introduce AsyncBatchFunction and AsyncBatchWaitOperator [flink] via GitHub
• Re: [PR] [FLINK-38825] Add time-based batch triggering for AsyncBatchWaitOperator [flink] via GitHub
  • Re: [PR] [FLINK-38825] Add time-based batch triggering for AsyncBatchWaitOperator [flink] via GitHub
• [jira] [Updated] (FLINK-38160) StarRocks Pipeline connector supports TIME/BINARY/VARBINARY type mapping ASF GitHub Bot (Jira)
• [PR] [FLINK-38160][starrocks] Add support for BINARY and VARBINARY types in StarRocks connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38160][starrocks] Add support for BINARY and VARBINARY types in StarRocks connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38160][starrocks] Add support for BINARY and VARBINARY types in StarRocks connector [flink-cdc] via GitHub
• [PR] Add unit tests for ConditionsUtils [flink-kubernetes-operator] via GitHub
  • Re: [PR] Add unit tests for ConditionsUtils [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39220] Add unit tests for ConditionsUtils [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39220] Add unit tests for ConditionsUtils [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39220] Add unit tests for ConditionsUtils [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39220] Add unit tests for ConditionsUtils [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39220] Add unit tests for ConditionsUtils [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39220] Add unit tests for ConditionsUtils [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39220] Add unit tests for ConditionsUtils [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39220] Add unit tests for ConditionsUtils [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39220] Add unit tests for ConditionsUtils [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39220] Add unit tests for ConditionsUtils [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39220] Add unit tests for ConditionsUtils [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39220] Add unit tests for ConditionsUtils [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39220] Add unit tests for ConditionsUtils [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39220] Add unit tests for ConditionsUtils [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39220] Add unit tests for ConditionsUtils [flink-kubernetes-operator] via GitHub
• [jira] [Created] (FLINK-39217) CompactCoordinator throws FileNotFoundException during snapshotState due to race condition with StreamWriter liu (Jira)
• [PR] [FLINK-39200][mysql] Skip insert/update/delete binlog deserialization of unsubscribed tables in MySql CDC binary log client. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39200][mysql] Skip insert/update/delete binlog deserialization of unsubscribed tables in MySql CDC binary log client. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39200][mysql] Skip insert/update/delete binlog deserialization of unsubscribed tables in MySql CDC binary log client. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39200][mysql] Skip insert/update/delete binlog deserialization of unsubscribed tables in MySql CDC binary log client. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39200][mysql] Skip insert/update/delete binlog deserialization of unsubscribed tables in MySql CDC binary log client. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39200][mysql] Skip insert/update/delete binlog deserialization of unsubscribed tables in MySql CDC binary log client. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39200][mysql] Skip insert/update/delete binlog deserialization of unsubscribed tables in MySql CDC binary log client. [flink-cdc] via GitHub

• Earlier messages
• Later messages