issues  

Messages by Thread

• [jira] [Assigned] (FLINK-38045) Refactor: Make transform operator stateless by building a createTableEventCache Leonard Xu (Jira)
• [jira] [Updated] (FLINK-38045) Refactor: Make transform operator stateless by building a createTableEventCache Leonard Xu (Jira)
  • [jira] [Updated] (FLINK-38045) Refactor: Make transform operator stateless by building a createTableEventCache Leonard Xu (Jira)
• Re: [PR] [FLINK-35713][common] Support set parallelism in source and sink [flink-cdc] via GitHub
• [PR] [FLINK-38068][model] Build uber jar for open-ai model (#26770) [flink] via GitHub
  • Re: [PR] [FLINK-38068][model] Build uber jar for open-ai model (#26770) [flink] via GitHub
  • Re: [PR] [FLINK-38068][model] Build uber jar for open-ai model (#26770) [flink] via GitHub
  • Re: [PR] [FLINK-38068][model] Build uber jar for open-ai model (#26770) [flink] via GitHub
  • Re: [PR] [FLINK-38068][model] Build uber jar for open-ai model (#26770) [flink] via GitHub
• [jira] [Commented] (FLINK-38045) Refactor: Make transform operator stateless by building a createTableEventCache wuzexian (Jira)
• [jira] [Commented] (FLINK-38079) Add Pipeline support for DateType and TimeType wuzexian (Jira)
• [jira] [Assigned] (FLINK-38079) Add Pipeline support for DateType and TimeType Yanquan Lv (Jira)
• [jira] [Comment Edited] (FLINK-36663) [Window]The first processWatermark() after Sliding Window restore may have extra expired data. Xuyang Zhong (Jira)
• [jira] [Assigned] (FLINK-38068) Fix distribution Shengkai Fang (Jira)
• [jira] [Commented] (FLINK-38068) Fix distribution Shengkai Fang (Jira)
  • [jira] [Commented] (FLINK-38068) Fix distribution dalongliu (Jira)
• [jira] [Updated] (FLINK-38087) Improve OperationExecutor error messages and Java stream usage ASF GitHub Bot (Jira)
• [PR] [FLINK-38087][sql-gateway] Improve OperationExecutor error messages and Java stream usage [flink] via GitHub
  • Re: [PR] [FLINK-38087][sql-gateway] Improve OperationExecutor error messages and Java stream usage [flink] via GitHub
  • Re: [PR] [FLINK-38087][sql-gateway] Improve OperationExecutor error messages and Java stream usage [flink] via GitHub
  • Re: [PR] [FLINK-38087][sql-gateway] Improve OperationExecutor error messages and Java stream usage [flink] via GitHub
  • Re: [PR] [FLINK-38087][sql-gateway] Improve OperationExecutor error messages and Java stream usage [flink] via GitHub
  • Re: [PR] [FLINK-38087][sql-gateway] Improve OperationExecutor error messages and Java stream usage [flink] via GitHub
  • Re: [PR] [FLINK-38087][sql-gateway] Improve OperationExecutor error messages and Java stream usage [flink] via GitHub
  • Re: [PR] [FLINK-38087][sql-gateway] Improve OperationExecutor error messages and Java stream usage [flink] via GitHub
  • Re: [PR] [FLINK-38087][sql-gateway] Improve OperationExecutor error messages and Java stream usage [flink] via GitHub
  • Re: [PR] [FLINK-38087][sql-gateway] Improve OperationExecutor error messages and Java stream usage [flink] via GitHub
  • Re: [PR] [FLINK-38087][sql-gateway] Improve OperationExecutor error messages and Java stream usage [flink] via GitHub
• [jira] [Created] (FLINK-38087) Improve OperationExecutor error messages and Java stream usage Mingliang Liu (Jira)
• [jira] [Updated] (FLINK-38086) Make ChangelogNormalize reusable if possible ASF GitHub Bot (Jira)
• [PR] [FLINK-38086][table] Make ChangelogNormalize reusable if possible [flink] via GitHub
  • Re: [PR] [FLINK-38086][table] Make ChangelogNormalize reusable if possible [flink] via GitHub
  • Re: [PR] [FLINK-38086][table] Make ChangelogNormalize reusable if possible [flink] via GitHub
  • Re: [PR] [FLINK-38086][table] Make ChangelogNormalize reusable if possible [flink] via GitHub
  • Re: [PR] [FLINK-38086][table] Make ChangelogNormalize reusable if possible [flink] via GitHub
  • Re: [PR] [FLINK-38086][table] Make ChangelogNormalize reusable if possible [flink] via GitHub
  • Re: [PR] [FLINK-38086][table] Make ChangelogNormalize reusable if possible [flink] via GitHub
  • Re: [PR] [FLINK-38086][table] Make ChangelogNormalize reusable if possible [flink] via GitHub
  • Re: [PR] [FLINK-38086][table] Make ChangelogNormalize reusable if possible [flink] via GitHub
  • Re: [PR] [FLINK-38086][table] Make ChangelogNormalize reusable if possible [flink] via GitHub
  • Re: [PR] [FLINK-38086][table] Make ChangelogNormalize reusable if possible [flink] via GitHub
  • Re: [PR] [FLINK-38086][table] Make ChangelogNormalize reusable if possible [flink] via GitHub
  • Re: [PR] [FLINK-38086][table] Make ChangelogNormalize reusable if possible [flink] via GitHub
  • Re: [PR] [FLINK-38086][table] Make ChangelogNormalize reusable if possible [flink] via GitHub
  • Re: [PR] [FLINK-38086][table] Make ChangelogNormalize reusable if possible [flink] via GitHub
  • Re: [PR] [FLINK-38086][table] Make ChangelogNormalize reusable if possible [flink] via GitHub
• [jira] [Created] (FLINK-38086) Make ChangelogNormalize reusable if possible Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-28648) Allow session deletion to block on any running job ASF GitHub Bot (Jira)
• [PR] [FLINK-28648][operator] Fix Cleanup Process for Session Cluster [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-28648][Kubernetes Operator] Allow session deletion to block on any running job [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-28648][Kubernetes Operator] Allow session deletion to block on any running job [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-28648][Kubernetes Operator] Allow session deletion to block on any running job [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-28648][Kubernetes Operator] Allow session deletion to block on any running job [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-28648][Kubernetes Operator] Allow session deletion to block on any running job [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-28648][Kubernetes Operator] Allow session deletion to block on any running job [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-28648][Kubernetes Operator] Allow session deletion to block on any running job [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-28648][Kubernetes Operator] Allow session deletion to block on any running job [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-28648][Kubernetes Operator] Allow session deletion to block on any running job [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-28648][Kubernetes Operator] Allow session deletion to block on any running job [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-28648][Kubernetes Operator] Allow session deletion to block on any running job [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-28648][Kubernetes Operator] Allow session deletion to block on any running job [flink-kubernetes-operator] via GitHub
• [jira] [Created] (FLINK-38085) Use buildx for Docker image creation Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-38084) Update model provider download doc Hao Li (Jira)
• [jira] [Created] (FLINK-38083) OBJECT_OF function's type don't get inferred correctly during comparison Ramin Gharib (Jira)
• [jira] [Assigned] (FLINK-38035) Security Vulnerability in PyFlink Logging Mechanism (PythonEnvUtils.java) Robert Metzger (Jira)
• [jira] (FLINK-38058) Add e2e test for fluss pipeline connector Mahesh Sambaram (Jira)
• [jira] [Updated] (FLINK-38082) User's async function timeout call may result in unexpected retries ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-38082) User's async function timeout call may result in unexpected retries lincoln lee (Jira)
  • [jira] [Updated] (FLINK-38082) User's async function timeout call may result in unexpected retries lincoln lee (Jira)
• [PR] [FLINK-38082][datastream] Avoid unexpected retries when user async function invokes completeExceptionally [flink] via GitHub
  • Re: [PR] [FLINK-38082][datastream] Avoid unexpected retries when user async function invokes completeExceptionally [flink] via GitHub
  • Re: [PR] [FLINK-38082][datastream] Avoid unexpected retries when user async function invokes completeExceptionally [flink] via GitHub
  • Re: [PR] [FLINK-38082][datastream] Avoid unexpected retries when user async function invokes completeExceptionally [flink] via GitHub
  • Re: [PR] [FLINK-38082][datastream] Avoid unexpected retries when user async function invokes completeExceptionally [flink] via GitHub
  • Re: [PR] [FLINK-38082][datastream] Avoid unexpected retries when user async function invokes completeExceptionally [flink] via GitHub
  • Re: [PR] [FLINK-38082][datastream] Avoid unexpected retries when user async function invokes completeExceptionally [flink] via GitHub
  • Re: [PR] [FLINK-38082][datastream] Avoid unexpected retries when user async function invokes completeExceptionally [flink] via GitHub
  • Re: [PR] [FLINK-38082][datastream] Avoid unexpected retries when user async function invokes completeExceptionally [flink] via GitHub
• [jira] [Created] (FLINK-38082) User's async function timeout call may result in unexpected retries lincoln lee (Jira)
• [jira] [Created] (FLINK-38081) FLIP-528: Support EXPLAIN EXECUTE STATEMENT SET Syntax in Flink SQL Ramin Gharib (Jira)
• [jira] [Commented] (FLINK-38032) Release Testing: Verify FLIP-519: Introduce async lookup key ordered mode Qilong Wang (Jira)
  • [jira] [Commented] (FLINK-38032) Release Testing: Verify FLIP-519: Introduce async lookup key ordered mode Qilong Wang (Jira)
  • [jira] [Commented] (FLINK-38032) Release Testing: Verify FLIP-519: Introduce async lookup key ordered mode Qilong Wang (Jira)
  • [jira] [Commented] (FLINK-38032) Release Testing: Verify FLIP-519: Introduce async lookup key ordered mode dalongliu (Jira)
• [jira] [Updated] (FLINK-38080) Avoid pushing down non-deterministic relNodes by mistake Qilong Wang (Jira)
• [jira] [Created] (FLINK-38080) Avoid pushing down non-deterministic relNodes by mistake Qilong Wang (Jira)
• [jira] [Updated] (FLINK-38079) Add Pipeline support for DateType and TimeType ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-38079) Add Pipeline support for DateType and TimeType Yanquan Lv (Jira)
• [PR] [FLINK-38079] Add Pipeline support for DateType and TimeType [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38079] Add Pipeline support for DateType and TimeType [flink-cdc] via GitHub
• [jira] [Created] (FLINK-38079) Add Pipeline support for DateType and TimeType wuzexian (Jira)
• [jira] [Created] (FLINK-38078) DataStream API Execution Configuration doc contains deleted API usage Zhanghao Chen (Jira)
• [jira] [Updated] (FLINK-38077) Cancel job upgrades may get stuck indefinitely if JM is missing Gyula Fora (Jira)
• [jira] [Assigned] (FLINK-38077) Cancel job upgrades may get stuck indefinitely if JM is missing Gyula Fora (Jira)
• [jira] [Created] (FLINK-38077) Cancel job upgrades may get stuck indefinitely if JM is missing Gyula Fora (Jira)
• [jira] [Updated] (FLINK-38017) [Release-2.1] Add release note for release 2.1 ASF GitHub Bot (Jira)
• Re: [PR] [FLINK-37737] Add support for GaussDB database type [flink-connector-jdbc] via GitHub
• [PR] [FLINK-38017][release] Add release note for release 2.1 [flink] via GitHub
  • Re: [PR] [FLINK-38017][release] Add release note for release 2.1 [flink] via GitHub
  • Re: [PR] [FLINK-38017][release] Add release note for release 2.1 [flink] via GitHub
  • Re: [PR] [FLINK-38017][release] Add release note for release 2.1 [flink] via GitHub
  • Re: [PR] [FLINK-38017][release] Add release note for release 2.1 [flink] via GitHub
  • Re: [PR] [FLINK-38017][release] Add release note for release 2.1 [flink] via GitHub
  • Re: [PR] [FLINK-38017][release] Add release note for release 2.1 [flink] via GitHub
  • Re: [PR] [FLINK-38017][release] Add release note for release 2.1 [flink] via GitHub
  • Re: [PR] [FLINK-38017][release] Add release note for release 2.1 [flink] via GitHub
  • Re: [PR] [FLINK-38017][release] Add release note for release 2.1 [flink] via GitHub
  • Re: [PR] [FLINK-38017][release] Add release note for release 2.1 [flink] via GitHub
  • Re: [PR] [FLINK-38017][release] Add release note for release 2.1 [flink] via GitHub
  • Re: [PR] [FLINK-38017][release] Add release note for release 2.1 [flink] via GitHub
  • Re: [PR] [FLINK-38017][release] Add release note for release 2.1 [flink] via GitHub
• [jira] [Updated] (FLINK-37913) Implement OBJECT_OF Function for Structured Type Value Construction ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-37913) Implement OBJECT_OF Function for Structured Type Value Construction Timo Walther (Jira)
  • [jira] [Updated] (FLINK-37913) Implement OBJECT_OF Function for Structured Type Value Construction Timo Walther (Jira)
• Re: [PR] [FLINK-37913][table] Add built-in OBJECT_OF function [flink] via GitHub
  • Re: [PR] [FLINK-37913][table] Add built-in OBJECT_OF function [flink] via GitHub
  • Re: [PR] [FLINK-37913][table] Add built-in OBJECT_OF function [flink] via GitHub
  • Re: [PR] [FLINK-37913][table] Add built-in OBJECT_OF function [flink] via GitHub
  • Re: [PR] [FLINK-37913][table] Add built-in OBJECT_OF function [flink] via GitHub
  • Re: [PR] [FLINK-37913][table] Add built-in OBJECT_OF function [flink] via GitHub
  • Re: [PR] [FLINK-37913][table] Add built-in OBJECT_OF function [flink] via GitHub
  • Re: [PR] [FLINK-37913][table] Add built-in OBJECT_OF function [flink] via GitHub
  • Re: [PR] [FLINK-37913][table] Add built-in OBJECT_OF function [flink] via GitHub
  • Re: [PR] [FLINK-37913][table] Add built-in OBJECT_OF function [flink] via GitHub
• [I] [Feature][api][runtime] Introduce metric mechanism [flink-agents] via GitHub
  • Re: [I] [Feature][api][runtime] Introduce metric mechanism [flink-agents] via GitHub
• [I] [Feature][runtime] Support async execution for actions [flink-agents] via GitHub
• [I] [Feature][api] Support ReAct Agent [flink-agents] via GitHub
  • Re: [I] [Feature][api] Support ReAct Agent [flink-agents] via GitHub
  • Re: [I] [Feature][api] Support ReAct Agent [flink-agents] via GitHub
• [I] [Feature][api] Introduce Prompt, Tool and ChatModel [flink-agents] via GitHub
  • Re: [I] [Feature][api] Introduce Prompt, Tool and ChatModel [flink-agents] via GitHub
  • Re: [I] [Feature][api] Introduce Prompt, Tool and ChatModel [flink-agents] via GitHub
  • Re: [I] [Feature][api] Introduce Prompt, Tool and ChatModel [flink-agents] via GitHub
  • Re: [I] [Feature][api] Introduce Prompt, Tool and ChatModel [flink-agents] via GitHub
  • Re: [I] [Feature][api] Introduce Prompt, Tool and ChatModel [flink-agents] via GitHub
• [I] [Feature][api][runtime] Support Short-Term Memory [flink-agents] via GitHub
  • Re: [I] [Feature][api][runtime] Support Short-Term Memory [flink-agents] via GitHub
• [I] [Feature][plan][runtime] Introduce Resource and Resource Provider [flink-agents] via GitHub
• [jira] [Closed] (FLINK-38076) Image for flink-kubernetes-operator 1.12.1 Gyula Fora (Jira)
• [jira] [Commented] (FLINK-38076) Image for flink-kubernetes-operator 1.12.1 Gyula Fora (Jira)
  • [jira] [Commented] (FLINK-38076) Image for flink-kubernetes-operator 1.12.1 fallenup (Jira)
  • [jira] [Commented] (FLINK-38076) Image for flink-kubernetes-operator 1.12.1 Gyula Fora (Jira)
• [jira] [Created] (FLINK-38076) Image for flink-kubernetes-operator 1.12.1 fallenup (Jira)
• [jira] [Updated] (FLINK-38075) [Window]Data loss when using ltz time. kaitian (Jira)
  • [jira] [Updated] (FLINK-38075) [Window]Data loss when using ltz time. kaitian (Jira)
  • [jira] [Updated] (FLINK-38075) [Window]Data loss when using ltz time. kaitian (Jira)
  • [jira] [Updated] (FLINK-38075) [Window]Data loss when using ltz time. kaitian (Jira)
• [jira] [Created] (FLINK-38075) [Window]Data loss when using ltz time. kaitian (Jira)
• [jira] [Assigned] (FLINK-38047) Bump cert-manager in the Kubernetes Operator Robert Metzger (Jira)
• [jira] [Resolved] (FLINK-38047) Bump cert-manager in the Kubernetes Operator Robert Metzger (Jira)
• Re: [PR] [FLINK-37645] Improve existsUnboundedSource by avoiding duplicate check transformations [flink] via GitHub
  • Re: [PR] [FLINK-37645] Improve existsUnboundedSource by avoiding duplicate check transformations [flink] via GitHub
• Re: [PR] [hotfix] [docs] Correct inaccurate description of JobMaster's role in Flink JobManager [flink] via GitHub
• Re: [PR] [FLINK-37357][table-planner]Migrating SqlNode conversion logic from SqlNodeToOperationConversion to SqlNodeConverters [flink] via GitHub
  • Re: [PR] [FLINK-37357][table-planner]Migrating SqlNode conversion logic from SqlNodeToOperationConversion to SqlNodeConverters [flink] via GitHub
• [PR] [Doc] Fix typo in Operations [flink-kubernetes-operator] via GitHub
  • Re: [PR] [Doc] Fix typo in Operations [flink-kubernetes-operator] via GitHub
  • Re: [PR] [Doc] Fix typo in Operations [flink-kubernetes-operator] via GitHub
  • Re: [PR] [Doc] Fix typo in Operations [flink-kubernetes-operator] via GitHub
• [jira] [Commented] (FLINK-38066) Release Testing: Verify FLIP-437: Support ML Models in Flink SQL Hao Li (Jira)
  • [jira] [Commented] (FLINK-38066) Release Testing: Verify FLIP-437: Support ML Models in Flink SQL dalongliu (Jira)
• [jira] [Comment Edited] (FLINK-36715) Changed behavior for filter push down for IS NOT DISTINCT FROM after Calcite upgrade to 1.33 Qilong Wang (Jira)
  • [jira] [Comment Edited] (FLINK-36715) Changed behavior for filter push down for IS NOT DISTINCT FROM after Calcite upgrade to 1.33 Qilong Wang (Jira)
• [jira] [Commented] (FLINK-36715) Changed behavior for filter push down for IS NOT DISTINCT FROM after Calcite upgrade to 1.33 Qilong Wang (Jira)
  • [jira] [Commented] (FLINK-36715) Changed behavior for filter push down for IS NOT DISTINCT FROM after Calcite upgrade to 1.33 Sergey Nuyanzin (Jira)
• [jira] [Resolved] (FLINK-34037) FLIP-398: Improve Serialization Configuration And Usage In Flink dalongliu (Jira)
• [jira] [Assigned] (FLINK-38067) Release Testing: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design dalongliu (Jira)
• Re: [D] Short-Term Memory Design [flink-agents] via GitHub
  • Re: [D] Short-Term Memory Design [flink-agents] via GitHub
  • Re: [D] Short-Term Memory Design [flink-agents] via GitHub
  • Re: [D] Short-Term Memory Design [flink-agents] via GitHub
  • Re: [D] Short-Term Memory Design [flink-agents] via GitHub
  • Re: [D] Short-Term Memory Design [flink-agents] via GitHub
  • Re: [D] Short-Term Memory Design [flink-agents] via GitHub
  • Re: [D] Short-Term Memory Design [flink-agents] via GitHub
  • Re: [D] Short-Term Memory Design [flink-agents] via GitHub
  • Re: [D] Short-Term Memory Design [flink-agents] via GitHub
• [PR] [FLINK-31691][table] Add built-in MAP_FROM_ENTRIES function. [flink] via GitHub
  • Re: [PR] [FLINK-31691][table] Add built-in MAP_FROM_ENTRIES function. [flink] via GitHub
  • Re: [PR] [FLINK-31691][table] Add built-in MAP_FROM_ENTRIES function. [flink] via GitHub
  • Re: [PR] [FLINK-31691][table] Add built-in MAP_FROM_ENTRIES function. [flink] via GitHub
• [jira] [Commented] (FLINK-36779) topn.cache.size metric is incorrect and non-changing during the time Qilong Wang (Jira)
• [jira] [Resolved] (FLINK-37992) Release Testing Instructions: Verify FLIP-506: Support Reuse Multiple Table Sinks in Planner dalongliu (Jira)
• [jira] [Assigned] (FLINK-38074) Release Testing: Verify FLIP-506: Support Reuse Multiple Table Sinks in Planner dalongliu (Jira)
• [jira] [Resolved] (FLINK-38074) Release Testing: Verify FLIP-506: Support Reuse Multiple Table Sinks in Planner dalongliu (Jira)
• [jira] (FLINK-34251) ClosureCleaner to include reference classes for non-serialization exception Mingliang Liu (Jira)
• Re: [PR] [hotfix] Remove mention of SplittableTimers in favor of InterruptibleTimers [flink] via GitHub
  • Re: [PR] [hotfix] Remove mention of SplittableTimers in favor of InterruptibleTimers [flink] via GitHub
  • Re: [PR] [hotfix] Remove mention of SplittableTimers in favor of InterruptibleTimers [flink] via GitHub
• [jira] [Commented] (FLINK-38067) Release Testing: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design Kartikey Pant (Jira)
  • [jira] [Commented] (FLINK-38067) Release Testing: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design Hao Li (Jira)
  • [jira] [Commented] (FLINK-38067) Release Testing: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design Hao Li (Jira)
  • [jira] [Commented] (FLINK-38067) Release Testing: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design dalongliu (Jira)
  • [jira] [Commented] (FLINK-38067) Release Testing: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design Hao Li (Jira)
  • [jira] [Commented] (FLINK-38067) Release Testing: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design Kartikey Pant (Jira)
  • [jira] [Commented] (FLINK-38067) Release Testing: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design dalongliu (Jira)
  • [jira] [Commented] (FLINK-38067) Release Testing: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design Kartikey Pant (Jira)
  • [jira] [Commented] (FLINK-38067) Release Testing: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design Hao Li (Jira)
  • [jira] [Commented] (FLINK-38067) Release Testing: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design Hao Li (Jira)

• Earlier messages
• Later messages