Messages by Thread
-
-
[jira] [Updated] (FLINK-39894) Change version in generated REST API specifications yml files when creating a new release branch
ASF GitHub Bot (Jira)
-
[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
-
[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
-
[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)
-
[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
-
[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
-
[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
-
[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: [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
-
[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
-
[PR] [doc] Scope Flink Agents Java Library install step to Java jobs (#751) [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] [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
-
[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
-
[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
-
[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
-
[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
-
[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
-
[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
-
[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
-
[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
-
[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
-
[PR] [hotfix][javadocs] Fix typos in subpartition, ZooKeeper utils and sink ExecNode comments [flink]
via GitHub
-
[jira] [Updated] (FLINK-39884) Free up additional disk space for CI runs
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39884][ci] Free up additional disk space for CI runs [flink]
via GitHub
-
[PR] [fix] Make agents block optional so infra-only YAML files load (#775) [flink-agents]
via GitHub
-
[jira] [Created] (FLINK-39884) Free up additional disk space for CI runs
Martijn Visser (Jira)
-
Re: [PR] [FLINK-38349][runtime] Address SpillingThread Zero-Division During Channel Merging Operations [flink]
via GitHub
-
[PR] [docs] Fix workflow agent quickstart code snippet and comment [flink-agents]
via GitHub
-
[PR] [doc] Link quickstarts to Flink integration guide [flink-agents]
via GitHub
-
[PR] [docs] Document custom job name in quickstart examples [flink-agents]
via GitHub
-
[PR] [bugfix][docs] Add missing Skills Agent Quickstart link to overview page [flink-agents]
via GitHub
-
[jira] [Commented] (FLINK-35711) LocalRecoveryITCase failed on AZP due to exit code: 127
Martijn Visser (Jira)
-
[PR] [FLINK-39846][BP 2.3][tests] Restore IPv6 guard and config in IPv6HostnamesITCase under AdaptiveScheduler [flink]
via GitHub
-
[jira] [Commented] (FLINK-39845) SavepointITCase.testStopWithSavepointFailsOverToSavepoint fails on AdaptiveScheduler after JUnit5 migration
Martijn Visser (Jira)
-
[PR] [fix] Reject parameter_types on Python YAML tools (#774) [flink-agents]
via GitHub
-
[I] [Bug] Workflow agent quickstart — code snippet out of sync with source, resources/skills breaks FileSource [flink-agents]
via GitHub
-
[PR] [docs] Polish react_agent doc: imports, runnable-example link, tool prerequisite, prompt & output-schema clarifications [flink-agents]
via GitHub
-
[I] [Tech Debt] Installation doc: wrong Maven version, Python 3.12 mismatch, macOS ARM64 pip failure undocumented [flink-agents]
via GitHub
-
[PR] [docs] Polish integrate_with_flink doc: self-contained snippets and language-scoped notes [flink-agents]
via GitHub
-
[PR] [bugfix][examples] Add static import for copyResource in YamlWorkflow… [flink-agents]
via GitHub
-
[I] [Bug] Overview page missing Skills Agent Quickstart link [flink-agents]
via GitHub
-
[I] [Bug] YAML agent quickstart — Java code block does not match actual source [flink-agents]
via GitHub
-
[PR] [bugfix][docs] Align skills agent quickstart doc model name with code (qwen3:8b → qwen3.5:9b) [flink-agents]
via GitHub
-
[I] [Bug] Skills agent quickstart — doc says qwen3:8b but code uses qwen3.5:9b [flink-agents]
via GitHub
-
[jira] [Created] (FLINK-39883) Support broadcast state in PTFs
Timo Walther (Jira)
-
[jira] [Closed] (FLINK-39255) Support late data in PTFs
Timo Walther (Jira)
-
[jira] [Closed] (FLINK-39820) Update delta join documentation with new features in 2.3
Xuyang Zhong (Jira)
-
[jira] [Comment Edited] (FLINK-39820) Update delta join documentation with new features in 2.3
Xuyang Zhong (Jira)
-
[I] [Tech Debt] Fix Memory documentation examples and clarify long-term memory isolation [flink-agents]
via GitHub
-
[I] [Tech Debt] Clarify Workflow Agent documentation around event emission and event metadata [flink-agents]
via GitHub