issues  

Messages by Thread

• [jira] [Created] (FLINK-38848) Catalog#getTable should indicate if it's for writing He Qi (Jira)
• [jira] [Updated] (FLINK-38753) Enrich more upsert keys by equiv expressions ASF GitHub Bot (Jira)
• [PR] [FLINK-38753] Enrich upsert keys by equi-join equivalences [flink] via GitHub
  • Re: [PR] [FLINK-38753] Enrich upsert keys by equi-join equivalences [flink] via GitHub
• [jira] [Created] (FLINK-38847) Incorrect construction of Postgres ConnectionPoolId Di Wu (Jira)
• [PR] Fix ConnectionPoolId to use username [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38847][Postgres-cdc] Fix ConnectionPoolId to use username [flink-cdc] via GitHub
• [jira] [Assigned] (FLINK-38804) The shutdown sequence is incorrect causes TaskManager is shutting down Rui Fan (Jira)
• [PR] [infra] Add doc-including label to indicate docs are included in the PR [flink-agents] via GitHub
  • Re: [PR] [infra] Add doc-including label to indicate docs are included in the PR [flink-agents] via GitHub
  • Re: [PR] [infra] Add doc-including label to indicate docs are included in the PR [flink-agents] via GitHub
  • Re: [PR] [infra] Add doc-including label to indicate docs are included in the PR [flink-agents] via GitHub
  • Re: [PR] [infra] Add doc-including label to indicate docs are included in the PR [flink-agents] via GitHub
• Re: [D] Label-Based Version Control Strategy [flink-agents] via GitHub
  • Re: [D] Label-Based Version Control Strategy [flink-agents] via GitHub
  • Re: [D] Label-Based Version Control Strategy [flink-agents] via GitHub
• [jira] [Updated] (FLINK-38846) Binlog client use LinkedList to store binlog content Jira
• [jira] [Created] (FLINK-38846) Binlog client use LinkedList to store binlog content Jira
• Re: [PR] [FLINK-38441][runtime] Fix ExecutionGraphCoLocationRestartTest failures [flink] via GitHub
• [jira] [Closed] (FLINK-38718) Display the number of tasks at slots level on the detailed TaskManager page. Ferenc Csaky (Jira)
• [jira] [Closed] (FLINK-38719) Display the number of tasks on the TaskManagers page. Ferenc Csaky (Jira)
• [jira] [Closed] (FLINK-38717) Display the load status of TaskManagers. Ferenc Csaky (Jira)
• [jira] [Assigned] (FLINK-38845) Add ArchivedApplicationStore to manage terminated applications Zhu Zhu (Jira)
• [jira] [Closed] (FLINK-38760) Add REST APIs for application query and cancellation Zhu Zhu (Jira)
• [jira] [Resolved] (FLINK-38775) Flink 2.2: update reference data for Migration Tests Ruan Hang (Jira)
• [jira] [Updated] (FLINK-38579) NonEquivCond in join and Filters pushed down in source should also affect the upstream changelog just like Filter in Calc ASF GitHub Bot (Jira)
• [PR] [FLINK-38579] Fix incorrect UB drop for filter on non-upsert key [flink] via GitHub
  • Re: [PR] [FLINK-38579] Fix incorrect UB drop for filter on non-upsert key [flink] via GitHub
  • Re: [PR] [FLINK-38579] Fix incorrect UB drop for filter on non-upsert key [flink] via GitHub
  • Re: [PR] [FLINK-38579] Fix incorrect UB drop for filter on non-upsert key [flink] via GitHub
• [jira] [Closed] (FLINK-38843) Flakey test case ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart RocMarshal (Jira)
• [jira] [Created] (FLINK-38845) Add ArchivedApplicationStore to manage terminated applications Yi Zhang (Jira)
• [PR] [plan] Support error handling strategy for built-in chat action. [flink-agents] via GitHub
  • Re: [PR] [plan] Support error handling strategy for built-in chat action. [flink-agents] via GitHub
• Re: [PR] [FLINK-37676][cdc-common] Add caching mechanism to Selectors for improved performance [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37676][cdc-common] Add caching mechanism to Selectors for improved performance [flink-cdc] via GitHub
• [PR] [FLINK-38819] Add debug logs for serialisation errors [flink] via GitHub
  • Re: [PR] [FLINK-38819] Add debug logs for serialisation errors [flink] via GitHub
  • Re: [PR] [FLINK-38819] Add debug logs for serialisation errors [flink] via GitHub
  • Re: [PR] [FLINK-38819] Add debug logs for serialisation errors [flink] via GitHub
  • Re: [PR] [FLINK-38819] Add debug logs for serialisation errors [flink] via GitHub
  • Re: [PR] [FLINK-38819] Add debug logs for serialisation errors [flink] via GitHub
  • Re: [PR] [FLINK-38819] Add debug logs for serialisation errors [flink] via GitHub
  • Re: [PR] [FLINK-38819] Add debug logs for serialisation errors [flink] via GitHub
  • Re: [PR] [FLINK-38819] Add debug logs for serialisation errors [flink] via GitHub
  • Re: [PR] [FLINK-38819] Add debug logs for serialisation errors [flink] via GitHub
  • Re: [PR] [FLINK-38819] Add debug logs for serialisation errors [flink] via GitHub
  • Re: [PR] [FLINK-38819] Add debug logs for serialisation errors [flink] via GitHub
• [PR] [common] Add PatternCache to optimize regex compilation performance [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-38844) Add metadata column support for PostgreSQL Pipeline Connector tchivs (Jira)
  • [jira] [Updated] (FLINK-38844) Add metadata column support for PostgreSQL Pipeline Connector ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-38844) Add metadata column support for PostgreSQL Pipeline Connector tchivs (Jira)
• [PR] [FLINK-XXXXX][pipeline-connector/postgres] Add metadata column support for PostgreSQL Pipeline Connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38844][pipeline-connector][postgres]Add metadata column support [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38844][pipeline-connector][postgres]Add metadata column support [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38844][pipeline-connector][postgres]Add metadata column support [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38844][pipeline-connector][postgres]Add metadata column support [flink-cdc] via GitHub
• [jira] [Created] (FLINK-38843) Flakey test case ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart RocMarshal (Jira)
• [jira] [Closed] (FLINK-38740) STDDEV related functions may produce invalid results lincoln lee (Jira)
• [jira] [Commented] (FLINK-38842) FileSink may leave orphaned temporary files in COS after restoring from a checkpoint, due to missing cleanup logic for temporary files in the checkpointed state. SkylerLin (Jira)
• [jira] [Created] (FLINK-38842) FileSink may leave orphaned temporary files in COS after restoring from a checkpoint, due to missing cleanup logic for temporary files in the checkpointed state. linguoxuan (Jira)
• [D] Flink Agents Support Multi-JDK Versions [flink-agents] via GitHub
• [D] Support Fine-Grain Durable Execution [flink-agents] via GitHub
• Re: [PR] [FLINK-37501][runtime/web] Fix incorrect job ID in url for logs in history server [flink] via GitHub
• [D] Improve Python Async Execution [flink-agents] via GitHub
  • Re: [D] Improve Python Async Execution API [flink-agents] via GitHub
• [PR] [hotfix] Fix build_docs GHA workflow not working after Java 11 upgrade [flink-cdc] via GitHub
  • Re: [PR] [hotfix] Fix build_docs GHA workflow not working after Java 11 upgrade [flink-cdc] via GitHub
• [PR] Add long-term memory documentation [flink-agents] via GitHub
• [PR] Add sensory memory documentation [flink-agents] via GitHub
  • Re: [PR] Add sensory memory documentation [flink-agents] via GitHub
• Re: [PR] [FLINK-37300][common] Add RawDataType to represent the type in data sources [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37300][common] Add RawDataType to represent the type in data sources [flink-cdc] via GitHub
• [jira] [Closed] (FLINK-38803) Add UNABLE_TO_DESERIALIZE_RESPONSE http-completion-state. Ferenc Csaky (Jira)
• [jira] [Assigned] (FLINK-38803) Add UNABLE_TO_DESERIALIZE_RESPONSE http-completion-state. Ferenc Csaky (Jira)
• Re: [PR] [FLINK-37984] Cassandra Sink V2 Implementation (FLIP-533) (Phase-1) [flink-connector-cassandra] via GitHub
  • Re: [PR] [FLINK-37984] Cassandra Sink V2 Implementation (FLIP-533) (Phase-1) [flink-connector-cassandra] via GitHub
• [jira] [Updated] (FLINK-38841) Nullability is lost in FamilyArgumentStrategy ASF GitHub Bot (Jira)
• [PR] [FLINK-38841][table] Enforce expected nullability in FamilyArgumentStrategy [flink] via GitHub
  • Re: [PR] [FLINK-38841][table] Enforce expected nullability in FamilyArgumentStrategy [flink] via GitHub
  • Re: [PR] [FLINK-38841][table] Enforce expected nullability in FamilyArgumentStrategy [flink] via GitHub
  • Re: [PR] [FLINK-38841][table] Enforce expected nullability in FamilyArgumentStrategy [flink] via GitHub
• [jira] [Resolved] (FLINK-38837) [doc] Add documentation for Hudi Pipeline Sink connector Leonard Xu (Jira)
• [PR] Add async execution support for built-in actions [flink-agents] via GitHub
  • Re: [PR] Add async execution support for built-in actions [flink-agents] via GitHub
• [jira] [Created] (FLINK-38841) Nullability is lost in FamilyArgumentStrategy dylanhz (Jira)
• [PR] Add documentation for adding Maven dependencies [flink-agents] via GitHub
  • Re: [PR] Add documentation for adding Maven dependencies [flink-agents] via GitHub
  • Re: [PR] Add documentation for adding Maven dependencies [flink-agents] via GitHub
  • Re: [PR] Add documentation for adding Maven dependencies [flink-agents] via GitHub
• [jira] [Resolved] (FLINK-38730) Bump jdk version of Flink CDC to 11 Leonard Xu (Jira)
• [jira] [Assigned] (FLINK-38730) Bump jdk version of Flink CDC to 11 Leonard Xu (Jira)
• [jira] [Closed] (FLINK-38759) Refactor application mode with PackagedProgramApplication Zhu Zhu (Jira)
• Re: [PR] [FLINK-36664][Window]Window with offset need deal offset when cal nextTriggerWatermark. [flink] via GitHub
• [jira] [Assigned] (FLINK-38801) Add Spotless plugin with Google AOSP style for flink benchmark repository Yuepeng Pan (Jira)
• [PR] [test] Use qwen3:8b in integration test to improve stability. [flink-agents] via GitHub
• [jira] [Commented] (FLINK-33383) flink-quickstart-scala.sh is not supported anymore since 1.17 but is used in flink-web helper scripts Sandesh Mendan (Jira)
• [jira] [Commented] (FLINK-23140) Invalid link in Data Sources documentation Sandesh Mendan (Jira)
• [jira] [Updated] (FLINK-38523) Upgrade Pekko to 1.2.0 ASF GitHub Bot (Jira)
• [PR] [FLINK-38523] Update Pekko to 1.4.0 [flink] via GitHub
  • Re: [PR] [FLINK-38523] Update Pekko to 1.4.0 [flink] via GitHub
  • Re: [PR] [FLINK-38523] Update Pekko to 1.4.0 [flink] via GitHub
  • Re: [PR] [FLINK-38523] Update Pekko to 1.4.0 [flink] via GitHub
  • Re: [PR] [FLINK-38523] Update Pekko to 1.4.0 [flink] via GitHub
  • Re: [PR] [FLINK-38523] Update Pekko to 1.4.0 [flink] via GitHub
  • Re: [PR] [FLINK-38523] Update Pekko to 1.4.0 [flink] via GitHub
  • Re: [PR] [FLINK-38523] Update Pekko to 1.4.0 [flink] via GitHub
  • Re: [PR] [FLINK-38523] Update Pekko to 1.4.0 [flink] via GitHub
  • Re: [PR] [FLINK-38523] Update Pekko to 1.4.0 [flink] via GitHub
  • Re: [PR] [FLINK-38523] Update Pekko to 1.4.0 [flink] via GitHub
  • Re: [PR] [FLINK-38523] Update Pekko to 1.4.0 [flink] via GitHub
  • Re: [PR] [FLINK-38523] Update Pekko to 1.4.0 [flink] via GitHub
  • Re: [PR] [FLINK-38523] Update Pekko to 1.4.0 [flink] via GitHub
  • Re: [PR] [FLINK-38523] Update Pekko to 1.4.0 [flink] via GitHub
  • Re: [PR] [FLINK-38523] Update Pekko to 1.4.0 [flink] via GitHub
  • Re: [PR] [FLINK-38523] Update Pekko to 1.4.0 [flink] via GitHub
  • Re: [PR] [FLINK-38523] Update Pekko to 1.4.0 [flink] via GitHub
  • Re: [PR] [FLINK-38523] Update Pekko to 1.4.0 [flink] via GitHub
  • Re: [PR] [FLINK-38523] Update Pekko to 1.4.0 [flink] via GitHub
  • Re: [PR] [FLINK-38523] Update Pekko to 1.4.0 [flink] via GitHub
  • Re: [PR] [FLINK-38523] Update Pekko to 1.4.0 [flink] via GitHub
  • Re: [PR] [FLINK-38523] Update Pekko to 1.4.0 [flink] via GitHub
  • Re: [PR] [FLINK-38523] Update Pekko to 1.4.0 [flink] via GitHub
• [jira] [Assigned] (FLINK-38840) Postgres YAML connector supports emitting complete Table ID Xiqian Yu (Jira)
• [jira] [Commented] (FLINK-38840) Postgres YAML connector supports emitting complete Table ID Xiqian Yu (Jira)
• [jira] [Created] (FLINK-38840) Postgres YAML connector supports emitting complete Table ID Xiqian Yu (Jira)
• Re: [PR] [FLINK-37575] Simplify the code for creating Netty shuffle environment. [flink] via GitHub
  • Re: [PR] [FLINK-37575] Simplify the code for creating Netty shuffle environment. [flink] via GitHub
• Re: [PR] [FLINK-37863] add DynamicKafkaSource interface [flink-connector-kafka] via GitHub
• [jira] [Commented] (FLINK-7288) Yarn production classes contain testing code Sandesh Mendan (Jira)
• [jira] [Commented] (FLINK-9680) Reduce heartbeat timeout for E2E tests Sandesh Mendan (Jira)
• [PR] doc : add ElasticsearchVectorStore doc [flink-agents] via GitHub
  • Re: [PR] doc : add ElasticsearchVectorStore doc [flink-agents] via GitHub
  • Re: [PR] doc : add ElasticsearchVectorStore doc [flink-agents] via GitHub
  • Re: [PR] doc : add ElasticsearchVectorStore doc [flink-agents] via GitHub
• [jira] [Updated] (FLINK-38837) [doc] Add documentation for Hudi Pipeline Sink connector ASF GitHub Bot (Jira)
• [PR] [FLINK-38837][pipeline-connector/hudi] Fix the configuraton for Hudi … [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38837][pipeline-connector/hudi] Fix the configuraton for Hudi … [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38837][pipeline-connector/hudi] Fix the configuraton for Hudi … [flink-cdc] via GitHub
• [PR] [FLINK-38839][runtime] Support semicolon delimiter for table-options [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38839][runtime] Support semicolon delimiter for table-options [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38839][runtime] Support semicolon delimiter for table-options [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38839][runtime] Support semicolon delimiter for table-options [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-38839) Support semicolon delimiter for transform table-options tchivs (Jira)
  • [jira] [Updated] (FLINK-38839) Support semicolon delimiter for transform table-options tchivs (Jira)
  • [jira] [Updated] (FLINK-38839) Support semicolon delimiter for transform table-options tchivs (Jira)
  • [jira] [Updated] (FLINK-38839) Support semicolon delimiter for transform table-options ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-38839) Support semicolon delimiter for transform table-options tchivs (Jira)
• [PR] [Feature][runtime] Support Multi-Version Flink for Flink Agents [flink-agents] via GitHub
  • Re: [PR] [Feature][runtime] Support Multi-Version Flink for Flink Agents [flink-agents] via GitHub
  • Re: [PR] [Feature][runtime] Support Multi-Version Flink for Flink Agents [flink-agents] via GitHub
• [I] [Feature] Support Multi-Version Flink for Flink Agents [flink-agents] via GitHub
  • Re: [I] [Feature] Support Multi-Version Flink for Flink Agents [flink-agents] via GitHub
• [jira] [Commented] (FLINK-23882) Documentation of TIMESTAMP WITH TIME ZONE should state that it is currently not supported by Flink SQL Sandesh Mendan (Jira)
• [jira] [Commented] (FLINK-24701) "late events" link in "Timely Stream Processing" document is not working Sandesh Mendan (Jira)
• [jira] [Commented] (FLINK-38823) Error running wide table task Thorne (Jira)
  • [jira] [Commented] (FLINK-38823) Error running wide table task peiyu (Jira)
  • [jira] [Commented] (FLINK-38823) Error running wide table task peiyu (Jira)
• [jira] [Resolved] (FLINK-38818) [posgtres-cdc] Emit initial table schemas from state Yanquan Lv (Jira)
• [jira] [Resolved] (FLINK-38834) Support alter column type DDL for starrocks sink connector Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38838) Update version of googleJavaFormat to AOSP 1.24.0 Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-38838) Update version of googleJavaFormat to AOSP 1.24.0 Yanquan Lv (Jira)
  • [jira] [Updated] (FLINK-38838) Update version of googleJavaFormat to AOSP 1.24.0 ASF GitHub Bot (Jira)
• [jira] [Comment Edited] (FLINK-38824) Incorrect default values for primitive types lincoln lee (Jira)
• [jira] [Assigned] (FLINK-37501) Incorrect url for jobmanager log on history server Yuepeng Pan (Jira)
• [PR] [metrics] Implement token usage metrics tracking for chat models [flink-agents] via GitHub
  • Re: [PR] [metrics] Implement token usage metrics tracking for chat models [flink-agents] via GitHub
  • Re: [PR] [metrics] Implement token usage metrics tracking for chat models [flink-agents] via GitHub
• [PR] Fix broken image links in the dynamic iceberg sink blogpost [flink-web] via GitHub
  • Re: [PR] Fix broken image links in the dynamic iceberg sink blogpost [flink-web] via GitHub
• Re: [PR] [FLINK-38432][python] Fix missing finish/reset for keyWriter/valueWriter in ArrowMapWriter [flink] via GitHub
• Re: [PR] [FLINK-37544] Replace Timer with single thread scheduled executor for BlobServer [flink] via GitHub
  • Re: [PR] [FLINK-37544] Replace Timer with single thread scheduled executor for BlobServer [flink] via GitHub
• Re: [PR] [FLINK-38438][Runtime] Support session mini cluster when use local ex… [flink] via GitHub
• Re: [PR] [FLINK-38392] Fix failing test in StreamPandasConversionTests [flink] via GitHub
• Re: [PR] [FLINK-38276][cdc-common] PaimonWriter does not invalidate cache when… [flink-cdc] via GitHub
• [jira] [Assigned] (FLINK-38827) NullPointerException and job restart when consuming from DynamoDB CDC Danny Cranmer (Jira)
• [I] [Feature] Add document for how to add dependency in pom for flink-agents project. [flink-agents] via GitHub
• [jira] [Updated] (FLINK-30252) Publish flink-shaded pom Martijn Visser (Jira)
• [PR] [released] Add Flink-Shaded 21.0 [flink-web] via GitHub
• [jira] [Assigned] (FLINK-38189) Allow it to sink data to Kafka partitions based on KEY in PyFlink Dian Fu (Jira)
• [PR] [runtime] Avoid create new runner context each time execute action. [flink-agents] via GitHub
  • Re: [PR] [runtime] Avoid create new runner context each time execute action. [flink-agents] via GitHub
• [jira] [Updated] (FLINK-38763) Add REST API for JarRunApplication ASF GitHub Bot (Jira)
• [PR] [FLINK-38763][runtime] Add REST API for JarRunApplication [flink] via GitHub
  • Re: [PR] [FLINK-38763][runtime] Add REST API for JarRunApplication [flink] via GitHub
• [jira] [Updated] (FLINK-38721) Support vector search for es connector ASF GitHub Bot (Jira)
• [D] Flink Agents: Flink Multi-Version Support Design [flink-agents] via GitHub
  • Re: [D] Flink Agents: Flink Multi-Version Support Design [flink-agents] via GitHub
  • Re: [D] Flink Multi-Version Support [flink-agents] via GitHub
  • Re: [D] Flink Multi-Version Support [flink-agents] via GitHub
• [PR] [FLINK-38721] Support vector search for es connector. [flink-connector-elasticsearch] via GitHub
  • Re: [PR] [FLINK-38721] Support vector search for es connector. [flink-connector-elasticsearch] via GitHub
  • Re: [PR] [FLINK-38721] Support vector search for es connector. [flink-connector-elasticsearch] via GitHub
• [jira] [Assigned] (FLINK-38825) Introduce an AI-friendly Async Batch Operator for high-latency inference workloads Dian Fu (Jira)
• [jira] [Assigned] (FLINK-38837) [doc] Add documentation for Hudi Pipeline Sink connector Leonard Xu (Jira)
• Re: [PR] [Draft] support overriding autoscaling scaling realizer via plugins [flink-kubernetes-operator] via GitHub
• [jira] [Commented] (FLINK-38837) [doc] Add documentation for Hudi Pipeline Sink connector Shuo Cheng (Jira)
  • [jira] [Commented] (FLINK-38837) [doc] Add documentation for Hudi Pipeline Sink connector Leonard Xu (Jira)
• [jira] [Closed] (FLINK-36797) hudi sink supports pipeline configuration connector Leonard Xu (Jira)

• Earlier messages
• Later messages