issues  

Messages by Date

• 2025/12/23 [jira] [Updated] (FLINK-38832) Projection pushdown of count(*) in planner changes Xuyang Zhong (Jira)
• 2025/12/23 [jira] [Updated] (FLINK-38832) Projection pushdown of count(*) in planner changes Xuyang Zhong (Jira)
• 2025/12/23 [jira] [Updated] (FLINK-38832) Projection pushdown of count(*) in planner changes Xuyang Zhong (Jira)
• 2025/12/23 [jira] [Updated] (FLINK-38832) Projection pushdown of count(*) in planner changes Hongshun Wang (Jira)
• 2025/12/23 [jira] [Updated] (FLINK-38832) Planner of count(*) changes Hongshun Wang (Jira)
• 2025/12/23 [jira] [Updated] (FLINK-38832) Planner of count(*) changes Hongshun Wang (Jira)
• 2025/12/23 [jira] [Updated] (FLINK-38832) Planner of count(*) changes Hongshun Wang (Jira)
• 2025/12/23 [jira] [Updated] (FLINK-38832) Planner of count(*) changes Hongshun Wang (Jira)
• 2025/12/23 [jira] [Created] (FLINK-38832) Planner of count(*) changes Hongshun Wang (Jira)
• 2025/12/23 Re: [PR] [FLINK-36313] Add Hudi sink connector support [flink-cdc] via GitHub
• 2025/12/23 [jira] [Commented] (FLINK-38831) The route configuration supports matching the first one Xiqian Yu (Jira)
• 2025/12/23 Re: [PR] [FLINK-36313] Add Hudi sink connector support [flink-cdc] via GitHub
• 2025/12/23 Re: [PR] [FLINK-38829][pipline-connector/starrocks] Support rename column DDL for starrocks sink connector [flink-cdc] via GitHub
• 2025/12/23 Re: [PR] [BP-2.2][FLINK-38824][table] Fix incorrect default values for primitive types [flink] via GitHub
• 2025/12/23 Re: [PR] [FLINK-38829][pipline-connector/starrocks] Support rename column DDL for starrocks sink connector [flink-cdc] via GitHub
• 2025/12/23 Re: [PR] [hotfix] [docs] Update overview.md with link to dependencies [flink] via GitHub
• 2025/12/23 Re: [PR] [hotfix] [docs] Update overview.md with link to dependencies [flink] via GitHub
• 2025/12/23 [PR] [hotfix] [docs] Update overview.md with link to dependencies [flink] via GitHub
• 2025/12/23 Re: [PR] [hotfix] [docs] Update overview.md with link to dependencies [flink] via GitHub
• 2025/12/23 Re: [PR] [hotfix] [docs] Update overview.md with link to dependencies [flink] via GitHub
• 2025/12/23 [PR] [hotfix] [docs] Update overview.md with link to dependencies [flink] via GitHub
• 2025/12/23 Re: [PR] [FLINK-38100] Bump Iceberg dependency to 1.10.0 in iceberg-pipeline-sink connector [flink-cdc] via GitHub
• 2025/12/23 Re: [PR] [Feature][Java] Add MCP support in Java [flink-agents] via GitHub
• 2025/12/23 Re: [PR] [hotfix] Rename flink-shaded-guava-33 to flink-shaded-guava-35 [flink-shaded] via GitHub
• 2025/12/23 Re: [PR] [FLINK-38829][pipline-connector/starrocks] Support rename column DDL for starrocks sink connector [flink-cdc] via GitHub
• 2025/12/23 [PR] [hotfix] Rename flink-shaded-guava-33 to flink-shaded-guava-35 [flink-shaded] via GitHub
• 2025/12/23 [jira] [Commented] (FLINK-38694) Update Flink Shaded dependencies Martijn Visser (Jira)
• 2025/12/23 [jira] [Closed] (FLINK-38694) Update Flink Shaded dependencies Martijn Visser (Jira)
• 2025/12/23 [jira] [Updated] (FLINK-38694) Update Flink Shaded dependencies Martijn Visser (Jira)
• 2025/12/23 Re: [I] upgrade flink 1.20 [flink-shaded] via GitHub
• 2025/12/23 Re: [I] Issue with Flink Application Mode args – Custom Command Not Executing as Expected [flink-shaded] via GitHub
• 2025/12/23 Re: [I] Issue with Flink Application Mode args – Custom Command Not Executing as Expected [flink-shaded] via GitHub
• 2025/12/23 Re: [I] upgrade flink 1.20 [flink-shaded] via GitHub
• 2025/12/23 [jira] [Assigned] (FLINK-38694) Update Flink Shaded dependencies Martijn Visser (Jira)
• 2025/12/23 Re: [PR] [FLINK-37811][Build/Shaded] Update Curator to 5.8.0 [flink-shaded] via GitHub
• 2025/12/23 Re: [PR] [FLINK-37811][Build/Shaded] Update Curator to 5.8.0 [flink-shaded] via GitHub
• 2025/12/23 Re: [PR] [FLINK-38694] Update dependencies to latest versions [flink-shaded] via GitHub
• 2025/12/23 Re: [PR] [FLINK-36313] Add Hudi sink connector support [flink-cdc] via GitHub
• 2025/12/23 [jira] [Updated] (FLINK-36313) Support pipeline sink hudi ASF GitHub Bot (Jira)
• 2025/12/23 Re: [PR] [FLINK-36313] Add Hudi sink connector support [flink-cdc] via GitHub
• 2025/12/23 [jira] [Resolved] (FLINK-38829) Support rename column DDL for starrocks sink connector Yanquan Lv (Jira)
• 2025/12/23 Re: [PR] [FLINK-38829][pipline-connector/starrocks] Support rename column DDL for starrocks sink connector [flink-cdc] via GitHub
• 2025/12/23 [jira] [Resolved] (FLINK-38813) Enable Flink CDC connectors to emit Debezium heartbeat events to downstream consumers Yanquan Lv (Jira)
• 2025/12/23 [jira] [Updated] (FLINK-36313) Support pipeline sink hudi Leonard Xu (Jira)
• 2025/12/23 [jira] [Assigned] (FLINK-36313) Support pipeline sink hudi Leonard Xu (Jira)
• 2025/12/23 Re: [PR] [FLINK-38813] : Support for emitting heartbeat events [flink-cdc] via GitHub
• 2025/12/23 Re: [D] Community Sync [flink-agents] via GitHub
• 2025/12/23 Re: [PR] [FLINK-38818] [posgtresql]Build createTableEventCache using TableSchemas from split [flink-cdc] via GitHub
• 2025/12/23 [jira] [Commented] (FLINK-38375) Flink Resouce leak on Flink k8s xiaolong3817 (Jira)
• 2025/12/23 [jira] [Commented] (FLINK-38375) Flink Resouce leak on Flink k8s xiaolong3817 (Jira)
• 2025/12/23 [jira] [Commented] (FLINK-38751) RowTimeRangeBoundedPrecedingFunction incorrectly cleans lastTriggeringTsState, may not discard expired data zzwqqq (Jira)
• 2025/12/22 Re: [PR] [BP-1.20][FLINK-38824][table] Fix incorrect default values for primitive types [flink] via GitHub
• 2025/12/22 [PR] [BP-1.20][FLINK-38824][table] Fix incorrect default values for primitive types [flink] via GitHub
• 2025/12/22 [jira] [Created] (FLINK-38831) The route configuration supports matching the first one peiyu (Jira)
• 2025/12/22 Re: [PR] [BP-2.2][FLINK-38824][table] Fix incorrect default values for primitive types [flink] via GitHub
• 2025/12/22 [PR] [BP-2.2][FLINK-38824][table] Fix incorrect default values for primitive types [flink] via GitHub
• 2025/12/22 [jira] [Commented] (FLINK-38817) Out of order data seen while running tpc-ds queries Zhu Zhu (Jira)
• 2025/12/22 [jira] [Comment Edited] (FLINK-38817) Out of order data seen while running tpc-ds queries Zhu Zhu (Jira)
• 2025/12/22 Re: [PR] [FLINK-37924][table]Introduce Built-in Function to Access field or element in the Variant [flink] via GitHub
• 2025/12/22 Re: [PR] [FLINK-36808][table-planner] Fix LookupJoin bug when used with filterable table source [flink] via GitHub
• 2025/12/22 [jira] [Commented] (FLINK-38817) Out of order data seen while running tpc-ds queries Zhu Zhu (Jira)
• 2025/12/22 [jira] [Commented] (FLINK-38432) Missing finish/reset for keyWriter/valueWriter in ArrowMapWriter Zhe Wang (Jira)
• 2025/12/22 Re: [PR] [Feature][Java] Add MCP support in Java [flink-agents] via GitHub
• 2025/12/22 Re: [PR] [Feature][Java] Add MCP support in Java [flink-agents] via GitHub
• 2025/12/22 Re: [PR] [FLINK-38762][runtime] Introduce SingleJobApplication [flink] via GitHub
• 2025/12/22 [jira] [Updated] (FLINK-38762) Introduce SingleJobApplication ASF GitHub Bot (Jira)
• 2025/12/22 [PR] [FLINK-38762][runtime] Introduce SingleJobApplication [flink] via GitHub
• 2025/12/22 Re: [PR] [FLINK-38740][table] Introduce Welford's online algorithm for variance related functions to avoid catastrophic cancellation in naive algorithm [flink] via GitHub
• 2025/12/22 [jira] [Updated] (FLINK-38828) PostTransformOperator needs to detect dynamic projection updates when restarting from checkpoint/savepoint Vinay Sagar Gonabavi (Jira)
• 2025/12/22 [jira] [Created] (FLINK-38830) PreTransformOperator needs to avoid crashing with "Field names must be unique" error and handle processing a duplicate AddColumnEvent better Vinay Sagar Gonabavi (Jira)
• 2025/12/22 [jira] [Updated] (FLINK-38828) PostTransformOperator needs to detect dynamic projection updates when restarting from checkpoint/savepoint Vinay Sagar Gonabavi (Jira)
• 2025/12/22 [jira] [Updated] (FLINK-38829) Support rename column DDL for starrocks sink connector ASF GitHub Bot (Jira)
• 2025/12/22 [PR] [FLINK-38829][pipline-connector/starrocks] Support rename column DDL for starrocks sink connector [flink-cdc] via GitHub
• 2025/12/22 [jira] [Updated] (FLINK-38828) PostTransformOperator cannot detect dynamic projection updates when restarting from checkpoint/savepoint Vinay Sagar Gonabavi (Jira)
• 2025/12/22 [jira] [Created] (FLINK-38829) Support rename column DDL for starrocks sink connector Mingliang Zhu (Jira)
• 2025/12/22 [jira] [Updated] (FLINK-38828) PostTransformOperator cannot detect dynamic projection updates when restarting from checkpoint/savepoint Vinay Sagar Gonabavi (Jira)
• 2025/12/22 [jira] [Updated] (FLINK-38828) PostTransformOperator cannot detect dynamic projection updates when restarting from checkpoint/savepoint Vinay Sagar Gonabavi (Jira)
• 2025/12/22 [jira] [Created] (FLINK-38828) PostTransformOperator cannot detect dynamic projection updates when restarting from checkpoint/savepoint Vinay Sagar Gonabavi (Jira)
• 2025/12/22 Re: [PR] [FLINK-37503] Compatibility Issue with MySQL Syntax SHOW MASTER STATUS [flink-cdc] via GitHub
• 2025/12/22 Re: [PR] [FLINK-37503] Compatibility Issue with MySQL Syntax SHOW MASTER STATUS [flink-cdc] via GitHub
• 2025/12/22 Re: [PR] [Feature][Java] Add MCP support in Java [flink-agents] via GitHub
• 2025/12/22 Re: [PR] [Feature][Java] Add MCP support in Java [flink-agents] via GitHub
• 2025/12/22 Re: [PR] [hotfix][runtime] Minor polish for the parameter naming of ExecutionGraphWithVertexParallelism#create. [flink] via GitHub
• 2025/12/22 Re: [PR] [hotfix][runtime] Minor polish for the parameter naming of ExecutionGraphWithVertexParallelism#create. [flink] via GitHub
• 2025/12/22 Re: [PR] [FLINK-38740][table] Introduce Welford's online algorithm for variance related functions to avoid catastrophic cancellation in naive algorithm [flink] via GitHub
• 2025/12/22 Re: [PR] [FLINK-38824][table] Fix incorrect default values for primitive types [flink] via GitHub
• 2025/12/22 [jira] [Updated] (FLINK-38824) Incorrect default values for primitive types lincoln lee (Jira)
• 2025/12/22 [jira] [Updated] (FLINK-38824) Incorrect default values for primitive types lincoln lee (Jira)
• 2025/12/22 [jira] [Closed] (FLINK-38824) Incorrect default values for primitive types lincoln lee (Jira)
• 2025/12/22 Re: [PR] [FLINK-38824][table] Fix incorrect default values for primitive types [flink] via GitHub
• 2025/12/22 Re: [PR] [FLINK-38694] Update dependencies to latest versions [flink-shaded] via GitHub
• 2025/12/22 [jira] [Commented] (FLINK-38532) FLIP-551: Make FRESHNESS Optional for Materialized Tables Hongshun Wang (Jira)
• 2025/12/22 [jira] [Updated] (FLINK-38827) NullPointerException and job restart when consuming from DynamoDB CDC Emre Kartoglu (Jira)
• 2025/12/22 [jira] [Updated] (FLINK-38827) NullPointerException and job restart when consuming from DynamoDB CDC Emre Kartoglu (Jira)
• 2025/12/22 [jira] [Updated] (FLINK-38827) [Draft] NullPointerException and job restart when consuming from DynamoDB CDC Emre Kartoglu (Jira)
• 2025/12/22 [jira] [Commented] (FLINK-38827) NullPointerException and job restart when consuming from DynamoDB CDC Emre Kartoglu (Jira)
• 2025/12/22 [jira] [Updated] (FLINK-38827) NullPointerException and job restart when consuming from DynamoDB CDC Emre Kartoglu (Jira)
• 2025/12/22 [jira] [Updated] (FLINK-38827) [Draft] NullPointerException and job restart when consuming from DynamoDB CDC Emre Kartoglu (Jira)
• 2025/12/22 [jira] [Updated] (FLINK-38827) [Draft] NullPointerException and job restart when consuming from DynamoDB CDC Emre Kartoglu (Jira)
• 2025/12/22 [jira] [Created] (FLINK-38827) NullPointerException and job restart when consuming from DynamoDB CDC Emre Kartoglu (Jira)
• 2025/12/22 Re: [PR] [api][runtime] Support use long-term memory in action and async compaction. [flink-agents] via GitHub
• 2025/12/22 Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc] via GitHub
• 2025/12/22 Re: [PR] [FLINK-38824][table] Fix incorrect default values for primitive types [flink] via GitHub
• 2025/12/22 Re: [PR] [FLINK-38774] Fixed incorrect handling of hidden directories when obtFixed incorrect handling of hidden directories when obtaining partition structureaining partiti… [flink] via GitHub
• 2025/12/22 Re: [PR] [FLINK-38694] Update dependencies to latest versions [flink-shaded] via GitHub
• 2025/12/22 Re: [PR] [Feature][Java] Add MCP support in Java [flink-agents] via GitHub
• 2025/12/22 Re: [PR] [FLINK-38824][table] Fix incorrect default values for primitive types [flink] via GitHub
• 2025/12/22 Re: [PR] [FLINK-38717][runtime] Display the load status of TaskManagers. [flink] via GitHub
• 2025/12/21 Re: [PR] [FLINK-38824][table] Fix incorrect default values for primitive types [flink] via GitHub
• 2025/12/21 [jira] [Created] (FLINK-38826) Add new ArgumentStrategy to support array with specified element type dylanhz (Jira)
• 2025/12/21 Re: [PR] [Feature][Java] Add MCP support in Java [flink-agents] via GitHub
• 2025/12/21 [I] [Feature] Update release infra to support multi-jdk version [flink-agents] via GitHub
• 2025/12/21 Re: [PR] [FLINK-33115] Add timeout for AbstractHadoopRecoverableWriterITCase to avoid hanging [flink] via GitHub
• 2025/12/21 Re: [PR] [Feature][Java] Add MCP support in Java [flink-agents] via GitHub
• 2025/12/21 [PR] [api][runtime] Support use long-term memory in action and async compaction. [flink-agents] via GitHub
• 2025/12/21 Re: [PR] [FLINK-38694] Update dependencies to latest versions [flink-shaded] via GitHub
• 2025/12/21 Re: [PR] [FLINK-38801][benchmark] Add Spotless and checkstyle plugins with Google AOSP style for flink benchmark repository [flink-benchmarks] via GitHub
• 2025/12/21 Re: [PR] [FLINK-38801][benchmark] Add Spotless and checkstyle plugins with Google AOSP style for flink benchmark repository [flink-benchmarks] via GitHub
• 2025/12/21 [jira] [Updated] (FLINK-38825) Introduce an AI-friendly Async Batch Operator for high-latency inference workloads featzhang (Jira)
• 2025/12/21 [jira] [Updated] (FLINK-38825) Introduce an AI-friendly Async Batch Operator for high-latency inference workloads featzhang (Jira)
• 2025/12/21 Re: [PR] [FLINK-38742][cdc-pipeline/postgres] Fix timestamp with time zone [flink-cdc] via GitHub
• 2025/12/21 Re: [PR] [FLINK-38825][python] Add Python DataStream API integration for AsyncBatchFunction [flink] via GitHub
• 2025/12/21 [PR] [FLINK-38825][python] Add Python DataStream API integration for AsyncBatchFunction [flink] via GitHub
• 2025/12/21 Re: [PR] [FLINK-38825][table] Add SQL/Table API integration for AsyncBatch inference [flink] via GitHub
• 2025/12/21 [PR] [FLINK-38825][table] Add SQL/Table API integration for AsyncBatch inference [flink] via GitHub
• 2025/12/21 Re: [PR] [FLINK-38825][streaming] Implement retry and timeout strategies for AsyncBatchWaitOperator [flink] via GitHub
• 2025/12/21 [PR] [FLINK-38825][streaming] Implement retry and timeout strategies for AsyncBatchWaitOperator [flink] via GitHub
• 2025/12/21 Re: [PR] [FLINK-38742][cdc-pipeline/postgres] Fix timestamp with time zone [flink-cdc] via GitHub
• 2025/12/21 Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc] via GitHub
• 2025/12/21 Re: [PR] [FLINK-38809][Tests] Upgrade Testcontainers to 2.0.3 [flink] via GitHub
• 2025/12/21 Re: [PR] [FLINK-38799][runtime] Rename `LoadingWeight` to `ResourceUnitCount` [flink] via GitHub
• 2025/12/21 Re: [PR] [FLINK-38824][table] Fix incorrect default values for primitive types [flink] via GitHub
• 2025/12/21 [jira] [Assigned] (FLINK-38824) Incorrect default values for primitive types lincoln lee (Jira)
• 2025/12/21 Re: [PR] [FLINK-38825][streaming] Add inference-oriented metrics to AsyncBatchWaitOperator [flink] via GitHub
• 2025/12/21 [PR] [FLINK-38825][streaming] Add inference-oriented metrics to AsyncBatchWaitOperator [flink] via GitHub
• 2025/12/21 Re: [PR] [FLINK-38825][streaming] Add ordered async batch support for AsyncBatchWaitOperator [flink] via GitHub
• 2025/12/21 [PR] [FLINK-38825][streaming] Add ordered async batch support for AsyncBatchWaitOperator [flink] via GitHub
• 2025/12/21 Re: [PR] [FLINK-38825] Add time-based batch triggering for AsyncBatchWaitOperator [flink] via GitHub
• 2025/12/21 Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc] via GitHub
• 2025/12/21 [PR] [FLINK-38825] Add time-based batch triggering for AsyncBatchWaitOperator [flink] via GitHub
• 2025/12/21 Re: [PR] [FLINK-38825] Introduce AsyncBatchFunction and AsyncBatchWaitOperator [flink] via GitHub
• 2025/12/21 [PR] [FLINK-38825] Introduce AsyncBatchFunction and AsyncBatchWaitOperator [flink] via GitHub
• 2025/12/21 [jira] [Updated] (FLINK-38825) Introduce an AI-friendly Async Batch Operator for high-latency inference workloads ASF GitHub Bot (Jira)
• 2025/12/21 [jira] [Updated] (FLINK-38825) Introduce an AI-friendly Async Batch Operator for high-latency inference workloads featzhang (Jira)
• 2025/12/21 [jira] [Created] (FLINK-38825) Introduce an AI-friendly Async Batch Operator for high-latency inference workloads featzhang (Jira)
• 2025/12/21 [jira] [Commented] (FLINK-38825) Introduce an AI-friendly Async Batch Operator for high-latency inference workloads featzhang (Jira)
• 2025/12/21 Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc] via GitHub
• 2025/12/20 Re: [PR] [FLINK-38824][table] Fix incorrect default values for primitive types [flink] via GitHub
• 2025/12/20 [jira] [Updated] (FLINK-38824) Incorrect default values for primitive types ASF GitHub Bot (Jira)
• 2025/12/20 [PR] [FLINK-38824][table] Fix incorrect default values for primitive types [flink] via GitHub
• 2025/12/20 [jira] [Updated] (FLINK-38824) Incorrect default values for primitive types dylanhz (Jira)
• 2025/12/20 [jira] [Updated] (FLINK-38824) Incorrect default values for primitive types dylanhz (Jira)
• 2025/12/20 [jira] [Created] (FLINK-38824) Incorrect default values for primitive types dylanhz (Jira)
• 2025/12/20 Re: [PR] [hotfix] Support passing arbitrary database options to JDBC Catalog [flink-connector-jdbc] via GitHub
• 2025/12/20 Re: [PR] [FLINK-38250] The Flink CDC type supports the timeTZ field type. [flink-cdc] via GitHub
• 2025/12/20 Re: [PR] [FLINK-38189][core][python] Add RowFieldExtractorSchema for Row field serialization [flink] via GitHub
• 2025/12/20 [jira] [Updated] (FLINK-38189) Allow it to sink data to Kafka partitions based on KEY in PyFlink ASF GitHub Bot (Jira)
• 2025/12/20 [PR] [FLINK-38189][core][python] Add RowFieldExtractorSchema for Row field serialization [flink] via GitHub
• 2025/12/19 Re: [PR] [improvement] adding runtime converter array [flink-cdc] via GitHub
• 2025/12/19 [PR] Bump org.apache.logging.log4j:log4j-core from 2.25.0 to 2.25.3 [flink-connector-kafka] via GitHub
• 2025/12/19 [PR] Bump org.apache.logging.log4j:log4j-core from 2.24.1 to 2.25.3 [flink-connector-opensearch] via GitHub
• 2025/12/19 [PR] Bump org.apache.logging.log4j:log4j-core from 2.23.1 to 2.25.3 [flink-connector-kudu] via GitHub
• 2025/12/19 [PR] Bump org.apache.logging.log4j:log4j-core from 2.23.1 to 2.25.3 [flink-connector-gcp-pubsub] via GitHub
• 2025/12/19 [PR] Bump org.apache.logging.log4j:log4j-core from 2.17.2 to 2.25.3 [flink-connector-mongodb] via GitHub
• 2025/12/19 [PR] Bump org.apache.logging.log4j:log4j-core from 2.17.2 to 2.25.3 [flink-connector-rabbitmq] via GitHub
• 2025/12/19 [PR] Bump org.apache.logging.log4j:log4j-core from 2.17.2 to 2.25.3 [flink-connector-jdbc] via GitHub
• 2025/12/19 Re: [PR] Bump org.apache.logging.log4j:log4j-core from 2.17.1 to 2.25.3 in /flink-connector-cassandra [flink-connector-cassandra] via GitHub
• 2025/12/19 [PR] Bump org.apache.logging.log4j:log4j-core from 2.17.1 to 2.25.3 in /flink-connector-cassandra [flink-connector-cassandra] via GitHub
• 2025/12/19 [jira] [Closed] (FLINK-38738) Incorrect UID for DataStreamScanProvider and TransformationScanProvider Timo Walther (Jira)
• 2025/12/19 Re: [PR] [FLINK-38738][table] Expose more context in table connectors to correct UID [flink] via GitHub
• 2025/12/19 [jira] (FLINK-38822) Extend URL_DECODE with a recursive parameter for multi-level decoding featzhang (Jira)
• 2025/12/19 [jira] [Commented] (FLINK-38822) Extend URL_DECODE with a recursive parameter for multi-level decoding featzhang (Jira)
• 2025/12/19 Re: [PR] [FLINK-38738][table] Expose more context in table connectors to correct UID [flink] via GitHub
• 2025/12/19 Re: [PR] [FLINK-38738][table] Expose more context in table connectors to correct UID [flink] via GitHub
• 2025/12/19 [PR] [FLINK-38738][table] Expose more context in table connectors to correct UID [flink] via GitHub
• 2025/12/19 Re: [PR] [FLINK-38822] Extend URL_DECODE with optional recursive decoding [flink] via GitHub
• 2025/12/19 [PR] [FLINK-38822] Extend URL_DECODE with optional recursive decoding [flink] via GitHub
• 2025/12/19 [jira] [Updated] (FLINK-38814) Kinesis Source in EFO - idle consumer on subscription failure ASF GitHub Bot (Jira)
• 2025/12/19 Re: [PR] [FLINK-38814][Connector/Kinesis] Kinesis Source in EFO - Fix idle consumer on subscription failure [flink-connector-aws] via GitHub
• 2025/12/19 Re: [PR] [FLINK-38742][cdc-pipeline/postgres] Fix timestamp with time zone [flink-cdc] via GitHub
• 2025/12/19 [jira] [Updated] (FLINK-38742) Postgres CDC pipeline fails when there is column of type TIMESTAMPTZ (timestamp with timezone) ASF GitHub Bot (Jira)
• 2025/12/19 [jira] [Updated] (FLINK-38823) Error running wide table task peiyu (Jira)
• 2025/12/19 Re: [PR] [FLINK-38742][cdc-pipeline/postgres] Fix timestamp with time zone [flink-cdc] via GitHub
• 2025/12/19 [jira] [Created] (FLINK-38823) Error running wide table task peiyu (Jira)
• 2025/12/18 Re: [PR] [FLINK-36816] Support source parallelism setting for JDBC connector [flink-connector-jdbc] via GitHub
• 2025/12/18 Re: [PR] [ci] Move the cross-language resource tests from the Python IT Test to the cross-language CI test [flink-agents] via GitHub
• 2025/12/18 Re: [I] [Feature] Batched Summarization for Long-Term Memory [flink-agents] via GitHub
• 2025/12/18 [jira] [Updated] (FLINK-38818) [posgtres-cdc] Emit initial table schemas from state ouyangwulin (Jira)
• 2025/12/18 [jira] [Updated] (FLINK-38758) Introduce PackagedProgramApplication Zhu Zhu (Jira)
• 2025/12/18 [jira] [Closed] (FLINK-38758) Introduce PackagedProgramApplication Zhu Zhu (Jira)
• 2025/12/18 Re: [PR] [FLINK-38758][runtime] Introduce PackagedProgramApplication [flink] via GitHub
• 2025/12/18 [jira] [Assigned] (FLINK-38818) [posgtres-cdc] Emit initial table schemas from state Xiqian Yu (Jira)
• 2025/12/18 [jira] [Updated] (FLINK-38818) [posgtres-cdc] Emit initial table schemas from state Xiqian Yu (Jira)
• 2025/12/18 Re: [PR] Add Hudi sink connector support [flink-cdc] via GitHub
• 2025/12/18 Re: [PR] Add Hudi sink connector support [flink-cdc] via GitHub
• 2025/12/18 Re: [I] [Feature] Batched Summarization for Long-Term Memory [flink-agents] via GitHub
• 2025/12/18 Re: [I] [Feature] Batched Summarization for Long-Term Memory [flink-agents] via GitHub
• 2025/12/18 Re: [I] [Feature] Batched Summarization for Long-Term Memory [flink-agents] via GitHub
• 2025/12/18 Re: [I] [Feature] Batched Summarization for Long-Term Memory [flink-agents] via GitHub
• 2025/12/18 [PR] [cdc-connector-mysql] Add MySQL 8.4+ compatibility for binlog status command [flink-cdc] via GitHub

• Earlier messages
• Later messages