issues  

Messages by Thread

• [PR] [runtime] Prune restored processing keys before snapshot [flink-agents] via GitHub
  • Re: [PR] [runtime] Prune restored processing keys before snapshot [flink-agents] via GitHub
  • Re: [PR] [runtime] Prune restored processing keys before snapshot [flink-agents] via GitHub
• [jira] [Closed] (FLINK-39894) Change version in generated REST API specifications yml files when creating a new release branch Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-39898) ProcessingTimeService timer callbacks delayed until checkpoint when mini-batch and unaligned checkpoints are enabled ion (Jira)
• Re: [PR] [FLINK-38770][runtime] Fix parallelism overrides ignored in Application Mode [flink] via GitHub
• Re: [PR] [FLINK-38804][runtime] Ensure channelStateWriter is closed after the inputGates [flink] via GitHub
• [jira] [Updated] (FLINK-39499) Replace MinIO in e2e tests with an Apache 2.0-licensed S3 alternative ASF GitHub Bot (Jira)
• [PR] [FLINK-39499] Replace MinIO with SeaweedFS [flink] via GitHub
  • Re: [PR] [FLINK-39499] Replace MinIO with SeaweedFS [flink] via GitHub
  • Re: [PR] [FLINK-39499] Replace MinIO with SeaweedFS [flink] via GitHub
  • Re: [PR] [FLINK-39499] Replace MinIO with SeaweedFS [flink] via GitHub
  • Re: [PR] [FLINK-39499] Replace MinIO with SeaweedFS [flink] via GitHub
  • Re: [PR] [FLINK-39499] Replace MinIO with SeaweedFS [flink] via GitHub
  • Re: [PR] [FLINK-39499] Replace MinIO with SeaweedFS [flink] via GitHub
  • Re: [PR] [FLINK-39499] Replace MinIO with SeaweedFS [flink] via GitHub
  • Re: [PR] [FLINK-39499] Replace MinIO with SeaweedFS [flink] via GitHub
• [PR] [BP-2.3][FLINK-39894][tools/releasing] Change version in generated REST API specifications yml files when creating a new release branch (#28365) [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-39894][tools/releasing] Change version in generated REST API specifications yml files when creating a new release branch [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-39894][tools/releasing] Change version in generated REST API specifications yml files when creating a new release branch [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-39894][tools/releasing] Change version in generated REST API specifications yml files when creating a new release branch [flink] via GitHub
• [jira] [Commented] (FLINK-39894) Change version in generated REST API specifications yml files when creating a new release branch Yuepeng Pan (Jira)
  • [jira] [Commented] (FLINK-39894) Change version in generated REST API specifications yml files when creating a new release branch Yuepeng Pan (Jira)
• [jira] [Closed] (FLINK-39755) RuntimeOpenRestAPIDocsCompletenessITCase fails for jdk 21+ Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-39755) RuntimeOpenRestAPIDocsCompletenessITCase fails for jdk 21+ Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-39897) limit() without an order produces invalid SQL ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-39897) limit() without an order produces invalid SQL Gustavo de Morais (Jira)
  • [jira] [Updated] (FLINK-39897) limit() without an order produces invalid SQL Gustavo de Morais (Jira)
  • [jira] [Updated] (FLINK-39897) limit() without an order produces invalid SQL Gustavo de Morais (Jira)
  • [jira] [Updated] (FLINK-39897) limit() without an order produces invalid SQL Gustavo de Morais (Jira)
  • [jira] [Updated] (FLINK-39897) limit() without an order produces invalid SQL Yuepeng Pan (Jira)
• [PR] [FLINK-39897][table] Fix SQL serialization when using limit without order [flink] via GitHub
  • Re: [PR] [FLINK-39897][table] Fix SQL serialization when using limit without order [flink] via GitHub
  • Re: [PR] [FLINK-39897][table] Fix SQL serialization when using limit without order [flink] via GitHub
  • Re: [PR] [FLINK-39897][table] Fix SQL serialization when using limit without order [flink] via GitHub
  • Re: [PR] [FLINK-39897][table] Fix SQL serialization when using limit without order [flink] via GitHub
• [jira] [Created] (FLINK-39897) limit() without an order produces invalid SQL Mika Naylor (Jira)
• [jira] [Assigned] (FLINK-39764) Support dynamic table options in Table API Mika Naylor (Jira)
• [jira] [Created] (FLINK-39896) FLIP-XXX: GEOGRAPHY type in Flink SQL and Table API David Chaava (Jira)
• [jira] [Closed] (FLINK-39895) PyFlink tests fail on release-1.20: setuptools 82 removed pkg_resources, breaking the Beam Python harness Martijn Visser (Jira)
• [jira] [Created] (FLINK-39895) PyFlink tests fail on release-1.20: setuptools 82 removed pkg_resources, breaking the Beam Python harness Martijn Visser (Jira)
• [PR] Flink 36753 test fail [flink] via GitHub
  • Re: [PR] Flink 36753 test fail [flink] via GitHub
  • Re: [PR] Flink 36753 test fail [flink] via GitHub
• [PR] [hotfix] fix depenedency version of kafka connector in documentation [flink-connector-kafka] via GitHub
  • Re: [PR] [hotfix] fix depenedency version of kafka connector in documentation [flink-connector-kafka] via GitHub
  • Re: [PR] [hotfix] fix depenedency version of kafka connector in documentation [flink-connector-kafka] via GitHub
  • Re: [PR] [hotfix] fix depenedency version of kafka connector in documentation [flink-connector-kafka] via GitHub
  • Re: [PR] [hotfix] fix depenedency version of kafka connector in documentation [flink-connector-kafka] via GitHub
  • Re: [PR] [hotfix] fix depenedency version of kafka connector in documentation [flink-connector-kafka] via GitHub
  • Re: [PR] [hotfix] fix depenedency version of kafka connector in documentation [flink-connector-kafka] via GitHub
• [jira] [Updated] (FLINK-39720) SubQueryDecorrelator produces incorrect plans for correlated EXISTS with HAVING on aggregate outputs lincoln lee (Jira)
  • [jira] [Updated] (FLINK-39720) SubQueryDecorrelator produces incorrect plans for correlated EXISTS with HAVING on aggregate outputs lincoln lee (Jira)
  • [jira] [Updated] (FLINK-39720) SubQueryDecorrelator produces incorrect plans for correlated EXISTS with HAVING on aggregate outputs Yuepeng Pan (Jira)
• [jira] [Closed] (FLINK-39720) SubQueryDecorrelator produces incorrect plans for correlated EXISTS with HAVING on aggregate outputs lincoln lee (Jira)
• [jira] [Comment Edited] (FLINK-39720) SubQueryDecorrelator produces incorrect plans for correlated EXISTS with HAVING on aggregate outputs lincoln lee (Jira)
• [I] [Bug] Stale processing keys in union list state can be snapshotted by non-owner subtasks [flink-agents] via GitHub
  • Re: [I] [Bug] Stale processing keys in union list state can be snapshotted by non-owner subtasks [flink-agents] via GitHub
  • Re: [I] [Bug] Stale processing keys in union list state can be snapshotted by non-owner subtasks [flink-agents] via GitHub
• [jira] [Updated] (FLINK-39894) Change version in generated REST API specifications yml files when creating a new release branch ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-39894) Change version in generated REST API specifications yml files when creating a new release branch Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-39894) Change version in generated REST API specifications yml files when creating a new release branch Yuepeng Pan (Jira)
• [PR] [FLINK-39894][tools/releasing] Change version in generated REST API specifications yml files when creating a new release branch [flink] via GitHub
  • Re: [PR] [FLINK-39894][tools/releasing] Change version in generated REST API specifications yml files when creating a new release branch [flink] via GitHub
  • Re: [PR] [FLINK-39894][tools/releasing] Change version in generated REST API specifications yml files when creating a new release branch [flink] via GitHub
  • Re: [PR] [FLINK-39894][tools/releasing] Change version in generated REST API specifications yml files when creating a new release branch [flink] via GitHub
  • Re: [PR] [FLINK-39894][tools/releasing] Change version in generated REST API specifications yml files when creating a new release branch [flink] via GitHub
  • Re: [PR] [FLINK-39894][tools/releasing] Change version in generated REST API specifications yml files when creating a new release branch [flink] via GitHub
  • Re: [PR] [FLINK-39894][tools/releasing] Change version in generated REST API specifications yml files when creating a new release branch [flink] via GitHub
• [jira] [Created] (FLINK-39894) Change version in generated REST API specifications yml files when creating a new release branch Yuepeng Pan (Jira)
• [PR] [FLINK-39755][tests] `RuntimeOpenRestAPIDocsCompletenessITCase` fails for jdk 21+ [flink] via GitHub
  • Re: [PR] [FLINK-39755][tests] `RuntimeOpenRestAPIDocsCompletenessITCase` fails for jdk 21+ [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-39755][tests] `RuntimeOpenRestAPIDocsCompletenessITCase` fails for jdk 21+ [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-39755][tests] `RuntimeOpenRestAPIDocsCompletenessITCase` fails for jdk 21+ [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-39755][tests] `RuntimeOpenRestAPIDocsCompletenessITCase` fails for jdk 21+ [flink] via GitHub
• [PR] [doc] Fix installation guide: Maven version, Python 3.12, macOS arm64 pip [flink-agents] via GitHub
  • Re: [PR] [doc] Fix installation guide: Maven version, Python 3.12, macOS arm64 pip [flink-agents] via GitHub
• [jira] [Created] (FLINK-39893) Respect non-monotonic counter accumulation in openTelemetry reporter Efrat Levitan (Jira)
• [jira] [Updated] (FLINK-39892) Exactly-once kafka sink reports a negative numBytesOut delta after every checkpoint ASF GitHub Bot (Jira)
• [PR] [FLINK-39892][metrics] Fix incorrect numBytesOut reported delta after producer reset [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-39892][metrics] Fix incorrect numBytesOut reported delta after producer reset [flink-connector-kafka] via GitHub
• [jira] [Created] (FLINK-39892) Exactly-once kafka sink reports a negative numBytesOut delta after every checkpoint Efrat Levitan (Jira)
• [I] [Feature] Add parallel LLM quickstart and example for multi-action fan-out [flink-agents] via GitHub
• [jira] [Assigned] (FLINK-39832) [Bug] Oracle pipeline connector maps NUMBER(p,0) with p>=19 to BIGINT, causing primary key collision and row collapse in downstream sinks Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-39891) Cancel orphaned session jobs on the session cluster before (re)submitting a FlinkSessionJob ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-39891) Cancel orphaned session jobs on the session cluster before (re)submitting a FlinkSessionJob lrsb (Jira)
• [PR] [FLINK-39891] Add option to cancel orphaned session jobs on submit [flink-kubernetes-operator] via GitHub
• [jira] [Created] (FLINK-39891) Cancel orphaned session jobs on the session cluster before (re)submitting a FlinkSessionJob lrsb (Jira)
• [jira] [Commented] (FLINK-39874) NativeS3RecoverableFsDataOutputStream leaks a temp file when the commit-time part upload fails, and uses non-idempotent deletes Li Guo (Jira)
• [PR] [hotfix][build] Bump netty to 4.2.15.Final (CVEs) [flink] via GitHub
  • Re: [PR] [hotfix][build] Bump netty to 4.2.15.Final [flink] via GitHub
  • Re: [PR] [hotfix][build] Bump netty to 4.2.15.Final [flink] via GitHub
• [jira] [Updated] (FLINK-39890) Autoscaler crashes with NumberFormatException computing observed scaling coefficient for idle vertices ASF GitHub Bot (Jira)
• [PR] [FLINK-39890] Fix NaN in observed scaling coefficient when baseline rate is zero [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39890] Fix NaN in observed scaling coefficient when baseline rate is zero [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39890] Fix NaN in observed scaling coefficient when baseline rate is zero [flink-kubernetes-operator] via GitHub
• [jira] [Created] (FLINK-39890) Autoscaler crashes with NumberFormatException computing observed scaling coefficient for idle vertices lrsb (Jira)
• [PR] [plan][runtime][java] Add CEL Action condition filtering [flink-agents] via GitHub
  • Re: [PR] [plan][runtime][java] Add CEL Action condition filtering [flink-agents] via GitHub
  • Re: [PR] [plan][runtime][java] Add CEL Action condition filtering [flink-agents] via GitHub
  • Re: [PR] [plan][runtime][java] Add CEL Action condition filtering [flink-agents] via GitHub
  • Re: [PR] [plan][runtime][java] Add CEL Action condition filtering [flink-agents] via GitHub
  • Re: [PR] [plan][runtime][java] Add CEL Action condition filtering [flink-agents] via GitHub
• [jira] [Updated] (FLINK-39755) RuntimeOpenRestAPIDocsCompletenessITCase fails for jdk 21+ Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-39755) RuntimeOpenRestAPIDocsCompletenessITCase fails for jdk 21+ Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-39755) RuntimeOpenRestAPIDocsCompletenessITCase fails for jdk 21+ Yuepeng Pan (Jira)
• [jira] [Reopened] (FLINK-39755) RuntimeOpenRestAPIDocsCompletenessITCase fails for jdk 21+ Yuepeng Pan (Jira)
• Re: [PR] Bump tar and @angular/cli in /flink-runtime-web/web-dashboard [flink] via GitHub
• Re: [PR] [FLINK-38096] AsyncSinkWriter may hang when configured with a custom rate limiting strategy [flink] via GitHub
• Re: [PR] [FLINK-34415] Move away from Kafka-Zookeeper based tests in favor of Kafka-KRaft [flink] via GitHub
• Re: [PR] [FLINK-39030][Table SQL/API] Support emit-only-on-update mode for CUMULATE window TVF to reduce unnecessary outputs [flink] via GitHub
• Re: [PR] [FLINK-38990][Runtime/Checkpointing] Support configurable initial delay for first checkpoint trigger [flink] via GitHub
• [PR] [hotfix] Add missing license header line in bash tool and skill modules [flink-agents] via GitHub
  • Re: [PR] [hotfix] Add missing license header line in bash tool and skill modules [flink-agents] via GitHub
• Re: [I] [Tech Debt] Refactoring CI of test cases in integration module [flink-agents] via GitHub
• Re: [PR] [ci] Refactor CI of test cases in integration module [flink-agents] via GitHub
• [PR] [doc] update "Native Integration Support Matrix" in FAQ [flink-agents] via GitHub
  • Re: [PR] [doc] update "Native Integration Support Matrix" in FAQ [flink-agents] via GitHub
• [jira] [Created] (FLINK-39889) Convert table sqlnode to operation Hao Li (Jira)
• [jira] (FLINK-39510) Add Chinese translation about AI-assisted contributions Nuozheng (Jira)
• Re: [I] [Feature][integration][Java] Java Implementation of Vector Store with Milvus Support [flink-agents] via GitHub
• Re: [I] [Feature] Support Fluss as ActionStateStore backend [flink-agents] via GitHub
• Re: [I] [Feature] [runtime] Support batched summarization for long-term memory. [flink-agents] via GitHub
  • Re: [I] [Feature] [runtime] Support batched summarization for long-term memory. [flink-agents] via GitHub
• [PR] [doc] Scope Flink Agents Java Library install step to Java jobs (#751) [flink-agents] via GitHub
  • Re: [PR] [doc] Scope Flink Agents Java Library install step to Java jobs [flink-agents] via GitHub
• [I] [Tech Debt] Update the FAQ section for release 0.3 [flink-agents] via GitHub
• [PR] [docs] Fix memory examples and clarify long-term memory isolation (#794) [flink-agents] via GitHub
  • Re: [PR] [docs] Fix memory examples and clarify long-term memory isolation (#794) [flink-agents] via GitHub
• Re: [PR] [FLINK-38814][Connector/Kinesis] Kinesis Source in EFO - Fix idle consumer on subscription failure [flink-connector-aws] via GitHub
• [jira] [Commented] (FLINK-39738) React to checkpoint ACK RPC failures Martijn Visser (Jira)
• [jira] [Resolved] (FLINK-39879) CheckpointAcknowledgeFailureITCase.testCheckpointAckFailure never CompletableFuture and hangs on Complete Martijn Visser (Jira)
• [jira] [Assigned] (FLINK-39879) CheckpointAcknowledgeFailureITCase.testCheckpointAckFailure never CompletableFuture and hangs on Complete Martijn Visser (Jira)
• [jira] [Updated] (FLINK-39888) [Kafka] Allow configuring offset reset strategy independently of startup offsets ASF GitHub Bot (Jira)
• [PR] [FLINK-39888][Kafka] Allow configuring offset reset strategy independently [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-39888][Kafka] Allow configuring offset reset strategy independently [flink-connector-kafka] via GitHub
• [PR] [DEBUG PR - DO NOT MERGE][FLINK-39481] Trace window-aggregate restore data loss [flink] via GitHub
  • Re: [PR] [DEBUG PR - DO NOT MERGE][FLINK-39481] Trace window-aggregate restore data loss [flink] via GitHub
• [jira] [Assigned] (FLINK-39888) [Kafka] Allow configuring offset reset strategy independently of startup offsets Xingcan Cui (Jira)
• [jira] [Updated] (FLINK-39874) NativeS3RecoverableFsDataOutputStream leaks a temp file when the commit-time part upload fails, and uses non-idempotent deletes ASF GitHub Bot (Jira)
• [PR] [FLINK-39874][filesystems] Fix temp file leak on commit-time upload f… [flink] via GitHub
  • Re: [PR] [FLINK-39874][filesystems] Fix temp file leak on commit-time upload f… [flink] via GitHub
  • Re: [PR] [FLINK-39874][filesystems] Fix temp file leak on commit-time upload f… [flink] via GitHub
  • Re: [PR] [FLINK-39874][filesystems] Fix temp file leak on commit-time upload f… [flink] via GitHub
  • Re: [PR] [FLINK-39874][filesystems] Fix temp file leak on commit-time upload f… [flink] via GitHub
  • Re: [PR] [FLINK-39874][filesystems] Fix temp file leak on commit-time upload f… [flink] via GitHub
  • Re: [PR] [FLINK-39874][filesystems] Fix temp file leak on commit-time upload f… [flink] via GitHub
  • Re: [PR] [FLINK-39874][filesystems] Fix temp file leak on commit-time upload f… [flink] via GitHub
• [jira] [Commented] (FLINK-39888) [Kafka] Allow configuring offset reset strategy independently of startup offsets Jigar Bhati (Jira)
  • [jira] [Commented] (FLINK-39888) [Kafka] Allow configuring offset reset strategy independently of startup offsets Jigar Bhati (Jira)
• [jira] [Created] (FLINK-39888) [Kafka] Allow configuring offset reset strategy independently of startup offsets Jigar Bhati (Jira)
• [jira] [Closed] (FLINK-39306) Align the busy-time TRUE_PROCESSING_RATE numerator estimator with the busy-time aggregator Gyula Fora (Jira)
• Re: [PR] [FLINK-39306][flink-autoscaler] Align the busy-time TRUE_PROCESSING_RATE numerator estimator with the busy-time aggregator [flink-kubernetes-operator] via GitHub
• Re: [PR] [FLINK-38753] [table-planner] Enrich upsert keys by equi-join equivalences [flink] via GitHub
  • Re: [PR] [FLINK-38753] [table-planner] Enrich upsert keys by equi-join equivalences [flink] via GitHub
  • Re: [PR] [FLINK-38753] [table-planner] Enrich upsert keys by equi-join equivalences [flink] via GitHub
  • Re: [PR] [FLINK-38753] [table-planner] Enrich upsert keys by equi-join equivalences [flink] via GitHub
  • Re: [PR] [FLINK-38753] [table-planner] Enrich upsert keys by equi-join equivalences [flink] via GitHub
• [jira] [Created] (FLINK-39887) Use validated query node as a fallback when parsing the raw asQuery fails Ramin Gharib (Jira)
• Re: [PR] [FLINK-38579] [table-planner] Fix incorrect UB drop for filter on non-upsert key [flink] via GitHub
  • Re: [PR] [FLINK-38579] [table-planner] Fix incorrect UB drop for filter on non-upsert key [flink] via GitHub
  • Re: [PR] [FLINK-38579] [table-planner] Fix incorrect UB drop for filter on non-upsert key [flink] via GitHub
  • Re: [PR] [FLINK-38579] [table-planner] Fix incorrect UB drop for filter on non-upsert key [flink] via GitHub
  • Re: [PR] [FLINK-38579] [table-planner] Fix incorrect UB drop for filter on non-upsert key [flink] via GitHub
• [jira] [Updated] (FLINK-39378) Add support for timers in ProcessTableFunctionTestHarness ASF GitHub Bot (Jira)
• [PR] [python][test] Add unit tests for tool schema conversion utilities [flink-agents] via GitHub
  • Re: [PR] [python][test] Add unit tests for tool schema conversion utilities [flink-agents] via GitHub
  • Re: [PR] [python][test] Add unit tests for tool schema conversion utilities [flink-agents] via GitHub
  • Re: [PR] [python][test] Add unit tests for tool schema conversion utilities [flink-agents] via GitHub
  • Re: [PR] [python][test] Add unit tests for tool schema conversion utilities [flink-agents] via GitHub
• [I] [Tech Debt] Add unit tests for tool schema conversion utilities (api/tools/utils.py) [flink-agents] via GitHub
  • Re: [I] [Tech Debt] Add unit tests for tool schema conversion utilities (api/tools/utils.py) [flink-agents] via GitHub
• [PR] [docs] Clarify Workflow Agent event emission and event metadata [flink-agents] via GitHub
  • Re: [PR] [docs] Clarify Workflow Agent event emission and event metadata [flink-agents] via GitHub
• [jira] [Updated] (FLINK-37655) Convert WindowStagger into an interface for easy extensibility Martijn Visser (Jira)
• [PR] [docs][yaml] Polish yaml doc and add bedrock alias [flink-agents] via GitHub
  • Re: [PR] [docs][yaml] Polish yaml doc and add bedrock alias [flink-agents] via GitHub
• [jira] [Closed] (FLINK-39885) Introduce ProcessSetTableOperator in PTF with Async State API Can Luo (Jira)
• [jira] [Created] (FLINK-39886) Introduce ProcessSetTableOperator in PTF with Async State API Can Luo (Jira)
• [PR] [FLINK-31244][core] Capture expected IllegalStateException on concurrent free in OffHeapUnsafeMemorySegmentTest [flink] via GitHub
  • Re: [PR] [FLINK-31244][core] Capture expected IllegalStateException on concurrent free in OffHeapUnsafeMemorySegmentTest [flink] via GitHub
  • Re: [PR] [FLINK-31244][core] Capture expected IllegalStateException on concurrent free in OffHeapUnsafeMemorySegmentTest [flink] via GitHub
  • Re: [PR] [FLINK-31244][core] Capture expected IllegalStateException on concurrent free in OffHeapUnsafeMemorySegmentTest [flink] via GitHub
  • Re: [PR] [FLINK-31244][core] Capture expected IllegalStateException on concurrent free in OffHeapUnsafeMemorySegmentTest [flink] via GitHub
  • Re: [PR] [FLINK-31244][core] Capture expected IllegalStateException on concurrent free in OffHeapUnsafeMemorySegmentTest [flink] via GitHub
  • Re: [PR] [FLINK-31244][core] Capture expected IllegalStateException on concurrent free in OffHeapUnsafeMemorySegmentTest [flink] via GitHub
• [jira] [Updated] (FLINK-31244) OffHeapUnsafeMemorySegmentTest.testCallCleanerOnceOnConcurrentFree prints IllegalStateException ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-39885) Introduce ProcessSetTableOperator in PTF with Async State API Can Luo (Jira)
• [PR] [examples] Quickstart process_chat_response fails fast on malformed JSON [flink-agents] via GitHub
  • Re: [PR] [examples] Quickstart process_chat_response fails fast on malformed JSON [flink-agents] via GitHub
• [jira] [Updated] (FLINK-39481) ⁠[tests] Fix flaky WindowDistinctAggregateITCase#testCumulateWindow_GroupingSets⁠ Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-39481) ⁠[tests] Fix flaky WindowDistinctAggregateITCase#testCumulateWindow_GroupingSets⁠ Martijn Visser (Jira)
• [jira] [Resolved] (FLINK-39882) Parser can not parse unparsed polymorphic table functions with several table args Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-39882) Parser can not parse unparsed polymorphic table functions with several table args Sergey Nuyanzin (Jira)
• [PR] [docs][examples] Clarify prompt brace handling and use single braces in JSON examples [flink-agents] via GitHub
  • Re: [PR] [docs][examples] Clarify prompt brace handling and use single braces in JSON examples [flink-agents] via GitHub
• [PR] [hotfix][javadocs] Fix typos in subpartition, ZooKeeper utils and sink ExecNode comments [flink] via GitHub
  • Re: [PR] [hotfix][javadocs] Fix typos in subpartition, ZooKeeper utils and sink ExecNode comments [flink] via GitHub
  • Re: [PR] [hotfix][javadocs] Fix typos in subpartition, ZooKeeper utils and sink ExecNode comments [flink] via GitHub
  • Re: [PR] [hotfix][javadocs] Fix typos in subpartition, ZooKeeper utils and sink ExecNode comments [flink] via GitHub

• Earlier messages
• Later messages