issues  

Messages by Thread

• • [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)
• [jira] [Comment Edited] (FLINK-38532) FLIP-551: Make FRESHNESS Optional for Materialized Tables Hongshun Wang (Jira)
• [jira] [Created] (FLINK-38837) [doc] Add documentation for Hudi Pipeline Sink connector Leonard Xu (Jira)
• [jira] [Resolved] (FLINK-36313) Support pipeline sink hudi Leonard Xu (Jira)
• [jira] [Assigned] (FLINK-38833) Partitioned fixed-bucket Paimon table write parallelism optimization Yanquan Lv (Jira)
• [jira] [Commented] (FLINK-38833) Partitioned fixed-bucket Paimon table write parallelism optimization Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-38831) The route configuration supports matching the first one Xiqian Yu (Jira)
  • [jira] [Updated] (FLINK-38831) The route configuration supports matching the first one ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-38836) Chinese documentation for pipeline configuration options is missing. peiyu (Jira)
• [jira] [Created] (FLINK-38835) When using postgresql cdc to read timestamp data with a value of 1900-01-01, abnormal data occurred Yanquan Lv (Jira)
• [PR] [FLINK-38834][pipline-connector/starrocks] Support alter column type DDL for starrocks sink connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38834][pipline-connector/starrocks] Support alter column type DDL for starrocks sink connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38834][pipline-connector/starrocks] Support alter column type DDL for starrocks sink connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38834][pipline-connector/starrocks] Support alter column type DDL for starrocks sink connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38834][pipline-connector/starrocks] Support alter column type DDL for starrocks sink connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38834][pipline-connector/starrocks] Support alter column type DDL for starrocks sink connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38834][pipline-connector/starrocks] Support alter column type DDL for starrocks sink connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38834][pipline-connector/starrocks] Support alter column type DDL for starrocks sink connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38834][pipline-connector/starrocks] Support alter column type DDL for starrocks sink connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38834][pipline-connector/starrocks] Support alter column type DDL for starrocks sink connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38834][pipline-connector/starrocks] Support alter column type DDL for starrocks sink connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38834][pipline-connector/starrocks] Support alter column type DDL for starrocks sink connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38834][pipline-connector/starrocks] Support alter column type DDL for starrocks sink connector [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-38834) Support alter column type DDL for starrocks sink connector Mingliang Zhu (Jira)
  • [jira] [Updated] (FLINK-38834) Support alter column type DDL for starrocks sink connector ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-38834) Support modify column type DDL for starrocks sink connector Mingliang Zhu (Jira)
• [jira] [Created] (FLINK-38833) Partitioned fixed-bucket Paimon table write parallelism optimization peiyu (Jira)
• [I] [Feature] Add metrics to record the token usage [flink-agents] via GitHub
  • Re: [I] [Feature] Add metrics to record the token usage [flink-agents] via GitHub
• [jira] [Commented] (FLINK-38832) Projection pushdown of count(*) in planner changes Xuyang Zhong (Jira)
• [jira] [Updated] (FLINK-38832) Projection pushdown of count(*) in planner changes Hongshun Wang (Jira)
  • [jira] [Updated] (FLINK-38832) Projection pushdown of count(*) in planner changes Xuyang Zhong (Jira)
  • [jira] [Updated] (FLINK-38832) Projection pushdown of count(*) in planner changes Xuyang Zhong (Jira)
  • [jira] [Updated] (FLINK-38832) Projection pushdown of count(*) in planner changes Xuyang Zhong (Jira)
• [jira] [Updated] (FLINK-38832) Planner of count(*) changes Hongshun Wang (Jira)
  • [jira] [Updated] (FLINK-38832) Planner of count(*) changes Hongshun Wang (Jira)
  • [jira] [Updated] (FLINK-38832) Planner of count(*) changes Hongshun Wang (Jira)
  • [jira] [Updated] (FLINK-38832) Planner of count(*) changes Hongshun Wang (Jira)
• [jira] [Created] (FLINK-38832) Planner of count(*) changes Hongshun Wang (Jira)
• [jira] [Commented] (FLINK-38831) The route configuration supports matching the first one Xiqian Yu (Jira)
  • [jira] [Commented] (FLINK-38831) The route configuration supports matching the first one peiyu (Jira)
  • [jira] [Commented] (FLINK-38831) The route configuration supports matching the first one SkylerLin (Jira)
  • [jira] [Commented] (FLINK-38831) The route configuration supports matching the first one Xiqian Yu (Jira)
  • [jira] [Commented] (FLINK-38831) The route configuration supports matching the first one SkylerLin (Jira)
  • [jira] [Commented] (FLINK-38831) The route configuration supports matching the first one yux (Jira)
• [PR] [hotfix] [docs] Update overview.md with link to dependencies [flink] via GitHub
  • Re: [PR] [hotfix] [docs] Update overview.md with link to dependencies [flink] via GitHub
  • Re: [PR] [hotfix] [docs] Update overview.md with link to dependencies [flink] via GitHub
  • [PR] [hotfix] [docs] Update overview.md with link to dependencies [flink] via GitHub
  • Re: [PR] [hotfix] [docs] Update overview.md with link to dependencies [flink] via GitHub
  • Re: [PR] [hotfix] [docs] Update overview.md with link to dependencies [flink] via GitHub
  • Re: [PR] [hotfix] [docs] Update overview.md with link to dependencies [flink] via GitHub
  • Re: [PR] [hotfix] [docs] Update overview.md with link to dependencies [flink] via GitHub
• [PR] [hotfix] Rename flink-shaded-guava-33 to flink-shaded-guava-35 [flink-shaded] via GitHub
  • Re: [PR] [hotfix] Rename flink-shaded-guava-33 to flink-shaded-guava-35 [flink-shaded] via GitHub
• [jira] [Commented] (FLINK-38694) Update Flink Shaded dependencies Martijn Visser (Jira)
• [jira] [Closed] (FLINK-38694) Update Flink Shaded dependencies Martijn Visser (Jira)
• Re: [I] Issue with Flink Application Mode args – Custom Command Not Executing as Expected [flink-shaded] via GitHub
  • Re: [I] Issue with Flink Application Mode args – Custom Command Not Executing as Expected [flink-shaded] via GitHub
• Re: [I] upgrade flink 1.20 [flink-shaded] via GitHub
  • Re: [I] upgrade flink 1.20 [flink-shaded] via GitHub
• [jira] [Assigned] (FLINK-38694) Update Flink Shaded dependencies Martijn Visser (Jira)
• Re: [PR] [FLINK-36313] Add Hudi sink connector support [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36313] Add Hudi sink connector support [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36313] Add Hudi sink connector support [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36313] Add Hudi sink connector support [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36313] Add Hudi sink connector support [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36313] Add Hudi sink connector support [flink-cdc] via GitHub
  • Re: [PR] [FLINK-36313] Add Hudi sink connector support [flink-cdc] via GitHub
• [jira] [Resolved] (FLINK-38829) Support rename column DDL for starrocks sink connector Yanquan Lv (Jira)
• [jira] [Resolved] (FLINK-38813) Enable Flink CDC connectors to emit Debezium heartbeat events to downstream consumers Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-36313) Support pipeline sink hudi Leonard Xu (Jira)
  • [jira] [Updated] (FLINK-36313) Support pipeline sink hudi ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-36313) Support pipeline sink hudi Leonard Xu (Jira)
• [jira] [Assigned] (FLINK-36313) Support pipeline sink hudi Leonard Xu (Jira)
• [jira] [Commented] (FLINK-38375) Flink Resouce leak on Flink k8s xiaolong3817 (Jira)
  • [jira] [Commented] (FLINK-38375) Flink Resouce leak on Flink k8s xiaolong3817 (Jira)
• [PR] [BP-1.20][FLINK-38824][table] Fix incorrect default values for primitive types [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-38824][table] Fix incorrect default values for primitive types [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-38824][table] Fix incorrect default values for primitive types [flink] via GitHub
• [jira] [Created] (FLINK-38831) The route configuration supports matching the first one peiyu (Jira)
• [PR] [BP-2.2][FLINK-38824][table] Fix incorrect default values for primitive types [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-38824][table] Fix incorrect default values for primitive types [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-38824][table] Fix incorrect default values for primitive types [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-38824][table] Fix incorrect default values for primitive types [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-38824][table] Fix incorrect default values for primitive types [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-38824][table] Fix incorrect default values for primitive types [flink] via GitHub
• Re: [PR] [FLINK-36808][table-planner] Fix LookupJoin bug when used with filterable table source [flink] via GitHub
• [jira] [Commented] (FLINK-38432) Missing finish/reset for keyWriter/valueWriter in ArrowMapWriter Zhe Wang (Jira)
• [jira] [Updated] (FLINK-38762) Introduce SingleJobApplication ASF GitHub Bot (Jira)
• [PR] [FLINK-38762][runtime] Introduce SingleJobApplication [flink] via GitHub
  • Re: [PR] [FLINK-38762][runtime] Introduce SingleJobApplication [flink] via GitHub
  • Re: [PR] [FLINK-38762][runtime] Introduce SingleJobApplication [flink] via GitHub
  • Re: [PR] [FLINK-38762][runtime] Introduce SingleJobApplication [flink] via GitHub
• [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)
• [jira] [Updated] (FLINK-38828) PostTransformOperator needs to detect dynamic projection updates when restarting from checkpoint/savepoint Vinay Sagar Gonabavi (Jira)
  • [jira] [Updated] (FLINK-38828) PostTransformOperator needs to detect dynamic projection updates when restarting from checkpoint/savepoint Vinay Sagar Gonabavi (Jira)
• [jira] [Updated] (FLINK-38829) Support rename column DDL for starrocks sink connector ASF GitHub Bot (Jira)
• [PR] [FLINK-38829][pipline-connector/starrocks] Support rename column DDL for starrocks sink connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38829][pipline-connector/starrocks] Support rename column DDL for starrocks sink connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38829][pipline-connector/starrocks] Support rename column DDL for starrocks sink connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38829][pipline-connector/starrocks] Support rename column DDL for starrocks sink connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38829][pipline-connector/starrocks] Support rename column DDL for starrocks sink connector [flink-cdc] via GitHub
• [jira] [Created] (FLINK-38829) Support rename column DDL for starrocks sink connector Mingliang Zhu (Jira)
• [jira] [Updated] (FLINK-38828) PostTransformOperator cannot detect dynamic projection updates when restarting from checkpoint/savepoint Vinay Sagar Gonabavi (Jira)
  • [jira] [Updated] (FLINK-38828) PostTransformOperator cannot detect dynamic projection updates when restarting from checkpoint/savepoint Vinay Sagar Gonabavi (Jira)
  • [jira] [Updated] (FLINK-38828) PostTransformOperator cannot detect dynamic projection updates when restarting from checkpoint/savepoint Vinay Sagar Gonabavi (Jira)
• [jira] [Created] (FLINK-38828) PostTransformOperator cannot detect dynamic projection updates when restarting from checkpoint/savepoint Vinay Sagar Gonabavi (Jira)
• Re: [PR] [FLINK-37503] Compatibility Issue with MySQL Syntax SHOW MASTER STATUS [flink-cdc] via GitHub
  • Re: [PR] [FLINK-37503] Compatibility Issue with MySQL Syntax SHOW MASTER STATUS [flink-cdc] via GitHub
• [jira] [Closed] (FLINK-38824) Incorrect default values for primitive types lincoln lee (Jira)
• [jira] [Commented] (FLINK-38532) FLIP-551: Make FRESHNESS Optional for Materialized Tables Hongshun Wang (Jira)
• [jira] [Commented] (FLINK-38827) NullPointerException and job restart when consuming from DynamoDB CDC Emre Kartoglu (Jira)
  • [jira] [Commented] (FLINK-38827) NullPointerException and job restart when consuming from DynamoDB CDC Danny Cranmer (Jira)
• [jira] [Updated] (FLINK-38827) NullPointerException and job restart when consuming from DynamoDB CDC Emre Kartoglu (Jira)
  • [jira] [Updated] (FLINK-38827) NullPointerException and job restart when consuming from DynamoDB CDC Emre Kartoglu (Jira)
  • [jira] [Updated] (FLINK-38827) NullPointerException and job restart when consuming from DynamoDB CDC Emre Kartoglu (Jira)
• [jira] [Updated] (FLINK-38827) [Draft] NullPointerException and job restart when consuming from DynamoDB CDC Emre Kartoglu (Jira)
  • [jira] [Updated] (FLINK-38827) [Draft] NullPointerException and job restart when consuming from DynamoDB CDC Emre Kartoglu (Jira)
  • [jira] [Updated] (FLINK-38827) [Draft] NullPointerException and job restart when consuming from DynamoDB CDC Emre Kartoglu (Jira)
• [jira] [Created] (FLINK-38827) NullPointerException and job restart when consuming from DynamoDB CDC Emre Kartoglu (Jira)
• [jira] [Created] (FLINK-38826) Add new ArgumentStrategy to support array with specified element type dylanhz (Jira)
• [I] [Feature] Update release infra to support multi-jdk version [flink-agents] via GitHub
• Re: [PR] [FLINK-33115] Add timeout for AbstractHadoopRecoverableWriterITCase to avoid hanging [flink] via GitHub
• [PR] [api][runtime] Support use long-term memory in action and async compaction. [flink-agents] via GitHub
  • Re: [PR] [api][runtime] Support use long-term memory in action and async compaction. [flink-agents] via GitHub
  • Re: [PR] [api][runtime] Support use long-term memory in action and async compaction. [flink-agents] via GitHub
• [PR] [FLINK-38825][python] Add Python DataStream API integration for AsyncBatchFunction [flink] via GitHub
  • Re: [PR] [FLINK-38825][python] Add Python DataStream API integration for AsyncBatchFunction [flink] via GitHub
• [PR] [FLINK-38825][table] Add SQL/Table API integration for AsyncBatch inference [flink] via GitHub
  • Re: [PR] [FLINK-38825][table] Add SQL/Table API integration for AsyncBatch inference [flink] via GitHub
• [PR] [FLINK-38825][streaming] Implement retry and timeout strategies for AsyncBatchWaitOperator [flink] via GitHub
  • Re: [PR] [FLINK-38825][streaming] Implement retry and timeout strategies for AsyncBatchWaitOperator [flink] via GitHub
• [jira] [Assigned] (FLINK-38824) Incorrect default values for primitive types lincoln lee (Jira)
• [PR] [FLINK-38825][streaming] Add inference-oriented metrics to AsyncBatchWaitOperator [flink] via GitHub
  • Re: [PR] [FLINK-38825][streaming] Add inference-oriented metrics to AsyncBatchWaitOperator [flink] via GitHub
• [PR] [FLINK-38825][streaming] Add ordered async batch support for AsyncBatchWaitOperator [flink] via GitHub
  • Re: [PR] [FLINK-38825][streaming] Add ordered async batch support for AsyncBatchWaitOperator [flink] via GitHub
• [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
• [PR] [FLINK-38825] Introduce AsyncBatchFunction and AsyncBatchWaitOperator [flink] via GitHub
  • Re: [PR] [FLINK-38825] Introduce AsyncBatchFunction and AsyncBatchWaitOperator [flink] via GitHub
• [jira] [Updated] (FLINK-38825) Introduce an AI-friendly Async Batch Operator for high-latency inference workloads featzhang (Jira)
  • [jira] [Updated] (FLINK-38825) Introduce an AI-friendly Async Batch Operator for high-latency inference workloads ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-38825) Introduce an AI-friendly Async Batch Operator for high-latency inference workloads featzhang (Jira)

• Earlier messages
• Later messages