issues  

Messages by Date

• 2026/01/08 Re: [PR] [FLINK-38189][core][python] Add RowFieldExtractorSchema for Row field serialization [flink] via GitHub
• 2026/01/08 [jira] [Updated] (FLINK-38596) The comment of the created MaxCompute table is incorrect ASF GitHub Bot (Jira)
• 2026/01/08 [PR] [FLINK-38596][pipeline][maxcompute] Fix the column comment of CreateTableEvent and AddColumnEvent [flink-cdc] via GitHub
• 2026/01/08 [I] [Feature] Simplify the custom event definition. [flink-agents] via GitHub
• 2026/01/08 [jira] [Updated] (FLINK-38577) FlinkBlueGreenDeployment Kubernetes Networking Update / Ingress not Stable ASF GitHub Bot (Jira)
• 2026/01/08 [PR] [FLINK-38577] Added BlueGreen active deployment ingress [flink-kubernetes-operator] via GitHub
• 2026/01/08 Re: [PR] [runtime] Support Fine-grain Durable Execution [flink-agents] via GitHub
• 2026/01/08 [jira] [Commented] (FLINK-38229) FLIP-490: Enhanced Job History Retention Policies for HistoryServer​ boxes (Jira)
• 2026/01/08 [jira] [Updated] (FLINK-38229) FLIP-490: Enhanced Job History Retention Policies for HistoryServer​ boxes (Jira)
• 2026/01/08 [I] [Feature] Support Fine-Grain Durable Execution [flink-agents] via GitHub
• 2026/01/08 Re: [PR] [FLINK-38845][runtime] Add ArchivedApplicationStore to manage terminated applications [flink] via GitHub
• 2026/01/08 [jira] [Closed] (FLINK-37902) Support batch execution for ML_PREDICT Shengkai Fang (Jira)
• 2026/01/08 [jira] [Assigned] (FLINK-37902) Support batch execution for ML_PREDICT Shengkai Fang (Jira)
• 2026/01/08 [jira] [Updated] (FLINK-37902) Support batch execution for ML_PREDICT Shengkai Fang (Jira)
• 2026/01/08 [jira] [Commented] (FLINK-37902) Support batch execution for ML_PREDICT Shengkai Fang (Jira)
• 2026/01/08 Re: [PR] [FLINK-37902] batch support for ml_predict [flink] via GitHub
• 2026/01/08 Re: [PR] [FLINK-37902] batch support for ml_predict [flink] via GitHub
• 2026/01/08 [jira] [Commented] (FLINK-38817) Out of order data seen while running tpc-ds queries Zhu Zhu (Jira)
• 2026/01/08 Re: [PR] [FLINK-38845][runtime] Add ArchivedApplicationStore to manage terminated applications [flink] via GitHub
• 2026/01/08 Re: [PR] [FLINK-38845][runtime] Add ArchivedApplicationStore to manage terminated applications [flink] via GitHub
• 2026/01/08 [PR] [runtime] Introduce CallRecord to ActionState [flink-agents] via GitHub
• 2026/01/08 Re: [PR] [FLINK-38808][pipeline-connector][iceberg] Support partition transforms in Iceberg sink [flink-cdc] via GitHub
• 2026/01/08 Re: [I] [Feature] Add document for Java MCP supports [flink-agents] via GitHub
• 2026/01/08 Re: [PR] [doc] Add doc for JAVA MCP Server tools and prompts [flink-agents] via GitHub
• 2026/01/08 Re: [PR] doc : add ElasticsearchVectorStore doc [flink-agents] via GitHub
• 2026/01/08 [jira] [Comment Edited] (FLINK-38817) Out of order data seen while running tpc-ds queries Bonnie Varghese (Jira)
• 2026/01/08 Re: [PR] [doc] Add doc for JAVA MCP Server tools and prompts [flink-agents] via GitHub
• 2026/01/08 Re: [PR] [FLINK-38810] Use splittable timers in Interval Join [flink] via GitHub
• 2026/01/08 [jira] [Updated] (FLINK-38530) create Dynamic Kafka Source for pyflink Bowen Li (Jira)
• 2026/01/08 Re: [PR] [FLINK-38810] Use splittable timers in Interval Join [flink] via GitHub
• 2026/01/08 [jira] [Updated] (FLINK-38876) Support per-cluster offset in Dynamic Kafka Source Bowen Li (Jira)
• 2026/01/08 Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
• 2026/01/08 [jira] [Assigned] (FLINK-38876) Support per-cluster offset in Dynamic Kafka Source Bowen Li (Jira)
• 2026/01/08 [jira] [Created] (FLINK-38876) Support per-cluster offset in Dynamic Kafka Source Bowen Li (Jira)
• 2026/01/08 [jira] [Updated] (FLINK-38876) Support per-cluster offset in Dynamic Kafka Source Bowen Li (Jira)
• 2026/01/08 [jira] [Updated] (FLINK-38263) Connection and secret factory ASF GitHub Bot (Jira)
• 2026/01/08 [PR] [FLINK-38263][table] add secret store related interfaces [flink] via GitHub
• 2026/01/08 [jira] [Updated] (FLINK-38871) PyFlink Planner incorrectly propagates constants into downstream UDF inputs when filtering on materialized ROW fields Vishal Kamlapure (Jira)
• 2026/01/08 Re: [PR] [FLINK-37924][table]Introduce Built-in Function to Access field or element in the Variant [flink] via GitHub
• 2026/01/08 Re: [PR] [FLINK-38816] use Flink 2 compatible deserialise [flink-connector-http] via GitHub
• 2026/01/08 Re: [PR] [FLINK-38447] Add table sink support for Elasticsearch 8 connector [flink-connector-elasticsearch] via GitHub
• 2026/01/08 Re: [PR] [Flink-38864] Add ignore status completion state [flink-connector-http] via GitHub
• 2026/01/08 Re: [PR] [FLINK-38733] Add new SplitterEnumerator on JdbcSource [flink-connector-jdbc] via GitHub
• 2026/01/08 Re: [PR] doc : add ElasticsearchVectorStore doc [flink-agents] via GitHub
• 2026/01/08 Re: [PR] [FLINK-37950][Connectors/MongoDB] Supporting ordered & bypassdocumentValidation behaviour for sink writer. [flink-connector-mongodb] via GitHub
• 2026/01/08 [jira] [Updated] (FLINK-38875) Bump Java Operator SDK to version 5.2.2 ASF GitHub Bot (Jira)
• 2026/01/08 [PR] [FLINK-38875] Bump Java Operator SDK to version 5.2.2 [flink-kubernetes-operator] via GitHub
• 2026/01/08 [jira] [Created] (FLINK-38875) Bump Java Operator SDK to version 5.2.2 Jira
• 2026/01/08 [jira] [Updated] (FLINK-38875) Bump Java Operator SDK to version 5.2.2 Jira
• 2026/01/08 [jira] [Updated] (FLINK-38845) Add ArchivedApplicationStore to manage terminated applications Yi Zhang (Jira)
• 2026/01/08 [jira] [Updated] (FLINK-38845) Add ArchivedApplicationStore to manage terminated applications Yi Zhang (Jira)
• 2026/01/08 [jira] [Commented] (FLINK-38874) Introduce VARIANT type and PARSE_JSON function to Flink CDC pipeline Yanquan Lv (Jira)
• 2026/01/08 [jira] [Assigned] (FLINK-38874) Introduce VARIANT type and PARSE_JSON function to Flink CDC pipeline Yanquan Lv (Jira)
• 2026/01/08 [jira] [Created] (FLINK-38874) Introduce VARIANT type and PARSE_JSON function to Flink CDC pipeline Yanquan Lv (Jira)
• 2026/01/08 Re: [I] [Feature] Support local execution in Java [flink-agents] via GitHub
• 2026/01/08 Re: [I] [Feature] Support local execution in Java [flink-agents] via GitHub
• 2026/01/08 Re: [PR] [FLINK-38790] Update to Flink 2.2 [flink-connector-kafka] via GitHub
• 2026/01/08 Re: [PR] [FLINK-38790] Update to Flink 2.2 [flink-connector-kafka] via GitHub
• 2026/01/08 Re: [PR] [FLINK-38790] Update to Flink 2.2 [flink-connector-kafka] via GitHub
• 2026/01/08 Re: [I] [Tech Debt] Improve Ollama related tests(start_ollama_server.sh) in CI [flink-agents] via GitHub
• 2026/01/08 Re: [I] [Tech Debt] Improve Ollama related tests(start_ollama_server.sh) in CI [flink-agents] via GitHub
• 2026/01/08 Re: [PR] [FLINK-38790] Update to Flink 2.2 [flink-connector-kafka] via GitHub
• 2026/01/08 [jira] [Commented] (FLINK-38853) Umbrella: FLIP-352: Enhance the standardization of the REST API JSON schema RocMarshal (Jira)
• 2026/01/08 [jira] [Commented] (FLINK-38853) Umbrella: FLIP-352: Enhance the standardization of the REST API JSON schema Matthias Pohl (Jira)
• 2026/01/08 [jira] [Updated] (FLINK-38853) Umbrella: FLIP-352: Enhance the standardization of the REST API JSON schema Matthias Pohl (Jira)
• 2026/01/08 [jira] [Commented] (FLINK-38853) Umbrella: FLIP-XXX: Enhance the standardization of the REST API JSON schema Matthias Pohl (Jira)
• 2026/01/08 Re: [PR] [FLINK-38447] Add table sink support for Elasticsearch 8 connector [flink-connector-elasticsearch] via GitHub
• 2026/01/08 Re: [PR] [FLINK-37924][table]Introduce Built-in Function to Access field or element in the Variant [flink] via GitHub
• 2026/01/08 Re: [I] [Tech Debt] Load integration from UserCodeClassloader. [flink-agents] via GitHub
• 2026/01/08 Re: [I] [Tech Debt] Load integration from UserCodeClassloader. [flink-agents] via GitHub
• 2026/01/08 Re: [PR] [FLINK-38845][runtime] Add ArchivedApplicationStore to manage terminated applications [flink] via GitHub
• 2026/01/08 [jira] [Commented] (FLINK-38596) The comment of the created MaxCompute table is incorrect SkylerLin (Jira)
• 2026/01/08 [jira] [Commented] (FLINK-34416) "Local recovery and sticky scheduling end-to-end test" still doesn't work with AdaptiveScheduler Matthias Pohl (Jira)
• 2026/01/07 Re: [PR] [doc] Add doc for JAVA MCP Server tools and prompts [flink-agents] via GitHub
• 2026/01/07 [jira] [Updated] (FLINK-38835) When using postgresql cdc to read timestamp data with a value of 1900-01-01, abnormal data occurred ASF GitHub Bot (Jira)
• 2026/01/07 [PR] [FLINK-38835][postgres] Fix timestamp conversion to LocalDateTime for dates before 1970-01-01. [flink-cdc] via GitHub
• 2026/01/07 Re: [PR] [FLINK-38848] [table] Supports to pass the required privilege when catalog manager gets the table [flink] via GitHub
• 2026/01/07 Re: [I] [Feature] Update release infra to support multi-jdk version [flink-agents] via GitHub
• 2026/01/07 Re: [PR] [Feature] Support multiple jdk versions [flink-agents] via GitHub
• 2026/01/07 Re: [PR] [hotfix] Avoid duplicate loop for configuration [flink] via GitHub
• 2026/01/07 Re: [PR] [FLINK-38848] [table] Supports to pass the required privilege when catalog manager gets the table [flink] via GitHub
• 2026/01/07 Re: [PR] [FLINK-38848] [table] Supports to pass the required privilege when catalog manager gets the table [flink] via GitHub
• 2026/01/07 [jira] [Assigned] (FLINK-38873) mysql pipeline error when adding the same column Yanquan Lv (Jira)
• 2026/01/07 [jira] [Created] (FLINK-38873) mysql pipeline error when adding the same column ouyangwulin (Jira)
• 2026/01/07 [jira] [Commented] (FLINK-38873) mysql pipeline error when adding the same column ouyangwulin (Jira)
• 2026/01/07 Re: [PR] [plan][hotfix] Avoid retrying chat even if response is valid. [flink-agents] via GitHub
• 2026/01/07 [jira] [Updated] (FLINK-38872) waitForAllTaskRunning Hang Indefinitely ConfX (Jira)
• 2026/01/07 [jira] [Created] (FLINK-38872) waitForAllTaskRunning Hang Indefinitely ConfX (Jira)
• 2026/01/07 Re: [PR] [FLINK-38838] Update spotless style version to AOSP 1.24.0 & reorganize CI modules [flink-cdc] via GitHub
• 2026/01/07 Re: [PR] [FLINK-38838] Update spotless style version to AOSP 1.24.0 & reorganize CI modules [flink-cdc] via GitHub
• 2026/01/07 Re: [PR] [doc] Add doc for JAVA MCP Server tools and prompts [flink-agents] via GitHub
• 2026/01/07 Re: [PR] [doc] Add doc for JAVA MCP Server tools and prompts [flink-agents] via GitHub
• 2026/01/07 [PR] [doc] Add doc for JAVA MCP Server tools and prompts [flink-agents] via GitHub
• 2026/01/07 [PR] [plan][hotfix] Avoid retrying chat even if response is valid. [flink-agents] via GitHub
• 2026/01/07 Re: [PR] [FLINK-38838] Update spotless style version to AOSP 1.24.0 & reorganize CI modules [flink-cdc] via GitHub
• 2026/01/07 Re: [PR] [FLINK-38838] Update spotless style version to AOSP 1.24.0 & reorganize CI modules [flink-cdc] via GitHub
• 2026/01/07 Re: [PR] [FLINK-38838] Update spotless style version to AOSP 1.24.0 & reorganize CI modules [flink-cdc] via GitHub
• 2026/01/07 Re: [PR] [FLINK-38848] [table] Supports to pass the required privilege when catalog manager gets the table [flink] via GitHub
• 2026/01/07 Re: [PR] [FLINK-38848] [table] Supports to pass the required privilege when catalog manager gets the table [flink] via GitHub
• 2026/01/07 [jira] [Closed] (FLINK-38100) Add BigQuery catalog support for iceberg pipeline sink connector Yanquan Lv (Jira)
• 2026/01/07 Re: [PR] [FLINK-38100] Bump Iceberg dependency to 1.10.1 in iceberg-pipeline-sink connector [flink-cdc] via GitHub
• 2026/01/07 Re: [PR] [Feature] Support multiple jdk versions [flink-agents] via GitHub
• 2026/01/07 Re: [I] [Feature] Add document for Java MCP supports [flink-agents] via GitHub
• 2026/01/07 Re: [I] [Feature] Support the use of Python MCP in Java [flink-agents] via GitHub
• 2026/01/07 Re: [I] [Feature] Support the use of Java MCP in Python [flink-agents] via GitHub
• 2026/01/07 Re: [I] [Feature] Support the use of Java MCP in Python [flink-agents] via GitHub
• 2026/01/07 Re: [PR] [FLINK-37902] batch support for ml_predict [flink] via GitHub
• 2026/01/07 Re: [I] [Feature] Add document for Java MCP supports [flink-agents] via GitHub
• 2026/01/07 [jira] [Updated] (FLINK-38871) PyFlink Planner incorrectly propagates constants into downstream UDF inputs when filtering on materialized ROW fields Vishal Kamlapure (Jira)
• 2026/01/07 [jira] [Commented] (FLINK-38871) PyFlink Planner incorrectly propagates constants into downstream UDF inputs when filtering on materialized ROW fields Vishal Kamlapure (Jira)
• 2026/01/07 [jira] [Created] (FLINK-38871) PyFlink Planner incorrectly propagates constants into downstream UDF inputs when filtering on materialized ROW fields Vishal Kamlapure (Jira)
• 2026/01/07 Re: [PR] Revert "[hotfix] Rename flink-shaded-guava-33 to flink-shaded-guava-35" [flink-shaded] via GitHub
• 2026/01/07 Re: [PR] [FLINK-38816] use Flink 2 compatible deserialise [flink-connector-http] via GitHub
• 2026/01/07 [PR] Add AWS Connectors 5.1.0 [flink-web] via GitHub
• 2026/01/07 [PR] Revert "[hotfix] Rename flink-shaded-guava-33 to flink-shaded-guava-35" [flink-shaded] via GitHub
• 2026/01/07 Re: [PR] [FLINK-38189][core][python] Add RowFieldExtractorSchema for Row field serialization [flink] via GitHub
• 2026/01/07 Re: [PR] [FLINK-38189][core][python] Add RowFieldExtractorSchema for Row field serialization [flink] via GitHub
• 2026/01/07 Re: [PR] [FLINK-38189][core][python] Add RowFieldExtractorSchema for Row field serialization [flink] via GitHub
• 2026/01/07 [jira] [Commented] (FLINK-38225) GSBlobStorageImpl needs to add precondition check to make 503 retryable Xi Zhang (Jira)
• 2026/01/07 Re: [PR] [FLINK-38225] Sets proper precondition to ensure that GCS operations are retryable [flink] via GitHub
• 2026/01/07 [jira] [Assigned] (FLINK-38869) InitializationContext for KafkaSubscriber Tzu-Li (Gordon) Tai (Jira)
• 2026/01/07 [jira] [Commented] (FLINK-38817) Out of order data seen while running tpc-ds queries Bonnie Varghese (Jira)
• 2026/01/07 Re: [PR] [FLINK-38848] [table] Supports to pass the required privilege when catalog manager gets the table [flink] via GitHub
• 2026/01/07 Re: [PR] [FLINK-38804][runtime] Ensure channelStateWriter is closed after the inputGates [flink] via GitHub
• 2026/01/07 Re: [PR] [FLINK-38804][runtime] Ensure channelStateWriter is closed after the inputGates [flink] via GitHub
• 2026/01/07 Re: [PR] [FLINK-38804][runtime] Ensure channelStateWriter is closed after the inputGates [flink] via GitHub
• 2026/01/07 Re: [PR] [FLINK-38804][runtime] Ensure channelStateWriter is closed after the inputGates [flink] via GitHub
• 2026/01/07 Re: [PR] [FLINK-38804][runtime] Ensure channelStateWriter is closed after the inputGates [flink] via GitHub
• 2026/01/07 Re: [PR] [FLINK-38804][runtime] Ensure channelStateWriter is closed after the inputGates [flink] via GitHub
• 2026/01/07 Re: [D] Community Sync - 2025 [flink-agents] via GitHub
• 2026/01/07 Re: [D] Community Sync - 2025 [flink-agents] via GitHub
• 2026/01/07 Re: [PR] [FLINK-38689] [flink-protobuf] Add support for protobuf 4.x field name conflict resolution [flink] via GitHub
• 2026/01/07 Re: [PR] [FLINK-38819] Add debug logs for serialisation errors [flink] via GitHub
• 2026/01/07 Re: [D] Community Sync - 2026 [flink-agents] via GitHub
• 2026/01/07 [D] Community Sync - 2026 [flink-agents] via GitHub
• 2026/01/07 Re: [PR] [api][integration][java] Enrich interface for vector store and implement these for elasticsearch. [flink-agents] via GitHub
• 2026/01/07 Re: [PR] [FLINK-38819] Add debug logs for serialisation errors [flink] via GitHub
• 2026/01/07 Re: [D] Community Sync - 2025 [flink-agents] via GitHub
• 2026/01/07 Re: [PR] [FLINK-38857][Model] Introduce a Triton inference module under flink-models for batch-oriented AI inference [flink] via GitHub
• 2026/01/07 Re: [PR] [FLINK-38857][Model] Introduce a Triton inference module under flink-models for batch-oriented AI inference [flink] via GitHub
• 2026/01/07 Re: [PR] [FLINK-38857][Model] Introduce a Triton inference module under flink-models for batch-oriented AI inference [flink] via GitHub
• 2026/01/07 Re: [PR] [FLINK-38857][Model] Introduce a Triton inference module under flink-models for batch-oriented AI inference [flink] via GitHub
• 2026/01/07 Re: [PR] [FLINK-38845][runtime] Add ArchivedApplicationStore to manage terminated applications [flink] via GitHub
• 2026/01/07 [jira] [Comment Edited] (FLINK-38703) ConcurrentModificationException in FineGrainedResourceManager during reporting metrics Matthias Pohl (Jira)
• 2026/01/07 [jira] [Resolved] (FLINK-38703) ConcurrentModificationException in FineGrainedResourceManager during reporting metrics Matthias Pohl (Jira)
• 2026/01/07 [jira] [Updated] (FLINK-38703) ConcurrentModificationException in FineGrainedResourceManager during reporting metrics Matthias Pohl (Jira)
• 2026/01/07 Re: [PR] [BP-1.20][FLINK-38703][runtime] Update slot manager metrics in thread-safety manner [flink] via GitHub
• 2026/01/07 Re: [PR] [BP-2.1][FLINK-38703][runtime] Update slot manager metrics in thread-safety manner [flink] via GitHub
• 2026/01/07 Re: [PR] [BP-2.2][FLINK-38703][runtime] Update slot manager metrics in thread-safety manner [flink] via GitHub
• 2026/01/07 Re: [PR] [BP-2.0][FLINK-38703][runtime] Update slot manager metrics in thread-safety manner [flink] via GitHub
• 2026/01/07 Re: [PR] [BP-2.0][FLINK-38703][runtime] Update slot manager metrics in thread-safety manner [flink] via GitHub
• 2026/01/07 Re: [PR] [FLINK-38848] [table] Supports to pass the required privilege when catalog manager gets the table [flink] via GitHub
• 2026/01/07 Re: [PR] [FLINK-38848] [table] Supports to pass the required privilege when catalog manager gets the table [flink] via GitHub
• 2026/01/07 Re: [I] [Feature] Support retry when llm response schema is not as expected. [flink-agents] via GitHub
• 2026/01/07 Re: [PR] [doc] Add doc for error handling strategy. [flink-agents] via GitHub
• 2026/01/07 Re: [PR] [FLINK-38848] [table] Supports to pass the required privilege when catalog manager gets the table [flink] via GitHub
• 2026/01/07 [PR] [doc] Add doc for error handling strategy. [flink-agents] via GitHub
• 2026/01/07 Re: [PR] [Feature][runtime] Support the use of Python EembeddingModel in Java [flink-agents] via GitHub
• 2026/01/07 Re: [I] [Feature] Support the use of Python EmbeddingModels in Java [flink-agents] via GitHub
• 2026/01/07 Re: [PR] [BP-1.20][FLINK-38703][runtime] Update slot manager metrics in thread-safety manner [flink] via GitHub
• 2026/01/07 Re: [PR] [FLINK-38816] use Flink 2 compatible deserialise [flink-connector-http] via GitHub
• 2026/01/07 Re: [PR] [BP-2.0][FLINK-38703][runtime] Update slot manager metrics in thread-safety manner [flink] via GitHub
• 2026/01/07 [PR] [BP-1.20][FLINK-38703][runtime] Update slot manager metrics in thread-safety manner [flink] via GitHub
• 2026/01/07 Re: [PR] [Flink-38864] Add ignore status completion state [flink-connector-http] via GitHub
• 2026/01/07 Re: [PR] [Flink-38864] Add ignore status completion state [flink-connector-http] via GitHub
• 2026/01/07 Re: [PR] [Feature] Support multiple jdk versions [flink-agents] via GitHub
• 2026/01/07 Re: [PR] [BP-2.0][FLINK-38703][runtime] Update slot manager metrics in thread-safety manner [flink] via GitHub
• 2026/01/07 Re: [PR] [FLINK-35061][table] Migrate TemporalJoinUtil to java [flink] via GitHub
• 2026/01/07 [jira] [Resolved] (FLINK-38862) Partition discovery interval not configurable in upsert mode (tableAPI) Fabian Paul (Jira)
• 2026/01/07 Re: [PR] [FLINK-38862] Configurable partition discovery interval in upsert mode [flink-connector-kafka] via GitHub
• 2026/01/07 Re: [PR] [FLINK-38862] Configurable partition discovery interval in upsert mode [flink-connector-kafka] via GitHub
• 2026/01/07 [jira] [Updated] (FLINK-38869) InitializationContext for KafkaSubscriber ASF GitHub Bot (Jira)
• 2026/01/07 [PR] [FLINK-38869] InitializationContext for KafkaSubscriber [flink-connector-kafka] via GitHub
• 2026/01/07 Re: [PR] [test] Use qwen3:8b in integration test to improve stability. [flink-agents] via GitHub
• 2026/01/07 Re: [PR] [test] Use qwen3:8b in integration test to improve stability. [flink-agents] via GitHub
• 2026/01/07 Re: [PR] [api][integration] Move mcp module from api to integration. [flink-agents] via GitHub
• 2026/01/07 Re: [PR] [Feature] Improve Python Async Execution API [flink-agents] via GitHub
• 2026/01/07 Re: [PR] [api][integration][java] Enrich interface for vector store and implement these for elasticsearch. [flink-agents] via GitHub
• 2026/01/07 Re: [I] [Feature] Improve Python Async Execution API [flink-agents] via GitHub
• 2026/01/07 [jira] [Updated] (FLINK-38870) Uninformative error message when job is suspended due to JobManager leadership loss ConfX (Jira)
• 2026/01/07 [jira] [Commented] (FLINK-38870) Uninformative error message when job is suspended due to JobManager leadership loss ConfX (Jira)
• 2026/01/07 [jira] [Created] (FLINK-38870) Uninformative error message when job is suspended due to JobManager leadership loss ConfX (Jira)
• 2026/01/06 Re: [PR] [BP-2.0][FLINK-38703][runtime] Update slot manager metrics in thread-safety manner [flink] via GitHub
• 2026/01/06 Re: [PR] [BP-2.1][FLINK-38703][runtime] Update slot manager metrics in thread-safety manner [flink] via GitHub
• 2026/01/06 Re: [PR] [BP-2.2][FLINK-38703][runtime] Update slot manager metrics in thread-safety manner [flink] via GitHub
• 2026/01/06 [PR] [BP-2.0][FLINK-38703][runtime] Update slot manager metrics in thread-safety manner [flink] via GitHub
• 2026/01/06 [PR] [BP-2.1][FLINK-38703][runtime] Update slot manager metrics in thread-safety manner [flink] via GitHub
• 2026/01/06 [PR] [BP-2.2][FLINK-38703][runtime] Update slot manager metrics in thread-safety manner [flink] via GitHub
• 2026/01/06 [PR] [Feature][runtime] Support the use of Python EembeddingModel in Java [flink-agents] via GitHub
• 2026/01/06 [PR] [api][integration][java] Enrich interface for vector store and implement these for elasticsearch. [flink-agents] via GitHub
• 2026/01/06 [jira] [Created] (FLINK-38869) InitializationContext for KafkaSubscriber Efrat Levitan (Jira)
• 2026/01/06 Re: [PR] [FLINK-38848] [table] Supports to pass the required privilege when catalog manager loads the table [flink] via GitHub
• 2026/01/06 Re: [PR] [FLINK-38848] [table] Supports to pass the required privilege when catalog manager loads the table [flink] via GitHub
• 2026/01/06 Re: [PR] [FLINK-37991][python] Upgrade pemja to 0.5.4 [flink] via GitHub
• 2026/01/06 Re: [PR] [FLINK-37991][python] Upgrade pemja to 0.5.4 [flink] via GitHub
• 2026/01/06 Re: [PR] [FLINK-36158][FOLLOWUP] Replace the ZK HA path from jobgraphs to execution-plans [flink] via GitHub
• 2026/01/06 Re: [PR] [FLINK-38848] [table] Supports to pass the required privilege when catalog manager loads the table [flink] via GitHub
• 2026/01/06 [jira] [Updated] (FLINK-38848) Catalog#getTable should indicate if it's for writing ASF GitHub Bot (Jira)
• 2026/01/06 [PR] [FLINK-38848] Supports to pass the required privilege when catalog manager loads the table [flink] via GitHub
• 2026/01/06 Re: [I] [Bug] Failed to connect to remote mcp server [flink-agents] via GitHub

• Earlier messages
• Later messages