Messages by Thread
-
[jira] [Updated] (FLINK-40586) DynamicKafkaSourceEnumerator re-signals NoMoreSplits to already-finished readers on every reader registration, causing "OperatorEvent lost" task failover
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40586][Connectors/Kafka] Signal no more splits to each reader once per registration [flink-connector-kafka]
via GitHub
-
[jira] [Commented] (FLINK-40586) DynamicKafkaSourceEnumerator re-signals NoMoreSplits to already-finished readers on every reader registration, causing "OperatorEvent lost" task failover
Bhanu Chander Vallabaneni (Jira)
-
[I] [Feature] Expose sub-agents to chat models as callable tools [flink-agents]
via GitHub
-
[jira] [Commented] (FLINK-40348) ZSTD fails at runtime with the SQL Kafka Connector
Bhanu Chander Vallabaneni (Jira)
-
Re: [PR] [FLINK-38830][runtime] Handle duplicate AddColumnEvent gracefully to prevent pipeline crashes [flink-cdc]
via GitHub
-
Re: [PR] [FLINK-39228][starrocks] Escape quoted default/comment literals in DDL [flink-cdc]
via GitHub
-
Re: [PR] [FLINK-39610] Mongo CDC supports specifying individual SSL context [flink-cdc]
via GitHub
-
[jira] [Updated] (FLINK-40354) StateTtlConfig background cleanup does not work for async State v2 MapState on ForSt state backend
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40354][state/forst] Configure the TTL compaction filter for State V2 states [flink]
via GitHub
-
Re: [PR] [FLINK-34246][runtime] Add option to only archive failed jobs to history server [flink]
via GitHub
-
[jira] [Assigned] (FLINK-40449) Reject non-temporal streaming sort during planning instead of at job submission
Martijn Visser (Jira)
-
[jira] [Commented] (FLINK-40606) Casting binary arrays generates invalid Java array allocation
Sergey Nuyanzin (Jira)
-
[jira] [Resolved] (FLINK-40606) Casting binary arrays generates invalid Java array allocation
Sergey Nuyanzin (Jira)
-
[jira] [Commented] (FLINK-39546) Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics
Samrat Deb (Jira)
-
[jira] (FLINK-40620) SourceTopicIntegrityTest.testTopicIntegritySuccess flaky - asserts exact record counts against at-least-once sink
Martijn Visser (Jira)
-
[jira] [Closed] (FLINK-40620) SourceTopicIntegrityTest.testTopicIntegritySuccess flaky - asserts exact record counts against at-least-once sink
Martijn Visser (Jira)
-
[jira] [Commented] (FLINK-40620) SourceTopicIntegrityTest.testTopicIntegritySuccess flaky - asserts exact record counts against at-least-once sink
Martijn Visser (Jira)
-
[jira] [Closed] (FLINK-40619) DynamicKafkaSourceReaderTest.testHandleSourceEventRetainsRemovedClusterOffsetsUntilExpired flaky - removed-cluster retention expiry cannot be tested deterministically
Martijn Visser (Jira)
-
[jira] [Assigned] (FLINK-40615) KafkaSourceEnumerator assigns duplicate splits when partition discovery interval is shorter than split initialization time
Martijn Visser (Jira)
-
Re: [PR] [FLINK-40449][table] Reject non-temporal streaming sort during planning [flink]
via GitHub
-
Re: [PR] [FLINK-33484][Connectors/Kafka] Fix offsets committed to Kafka [flink-connector-kafka]
via GitHub
-
Re: [PR] [api][plan][runtime] Introduce AGENT resource type and sub-agent invocation API [flink-agents]
via GitHub
-
[PR] [FLINK-40618][tests] Run SourceTopicIntegrity test in the integration-test phase [flink-connector-kafka]
via GitHub
-
[PR] [FLINK-40598][docs] Synchronize Chinese Elastic Scaling documentation [flink]
via GitHub
-
[PR] Bump @vitest/mocker and vitest in /flink-runtime-web/web-dashboard [flink]
via GitHub
-
Re: [PR] [FLINK-39200][mysql] Skip insert/update/delete binlog deserialization of unsubscribed tables in MySql CDC binary log client. [flink-cdc]
via GitHub
-
[jira] [Updated] (FLINK-40618) Connectors/Kafka: Run SourceTopicIntegrity test in the integration-test phase
Purushottam Sinha (Jira)
-
Re: [PR] [integrations][gemini] Cover buildConfig with unit tests [flink-agents]
via GitHub
-
[PR] [FLINK-40620][source/tests] Split SourceTopicIntegrityTest by guarantee [flink-connector-kafka]
via GitHub
-
[jira] [Updated] (FLINK-40620) SourceTopicIntegrityTest.testTopicIntegritySuccess flaky - asserts exact record counts against at-least-once sink
Dale Lane (Jira)
-
[jira] [Updated] (FLINK-40604) AsyncWaitOperator bypasses timeout handler when retry result mail runs after the deadline
David Peacock (Jira)
-
[PR] [dist] Shade and relocate kafka-clients and jackson in flink-agents-dist [flink-agents]
via GitHub
-
[jira] [Commented] (FLINK-23758) PyFlink __invert__ has wrong semantics
Bettle (Jira)
-
[PR] [FLINK-23758][python] Fix semantics of Expression.__invert__ [flink]
via GitHub
-
[jira] [Updated] (FLINK-40619) DynamicKafkaSourceReaderTest.testHandleSourceEventRetainsRemovedClusterOffsetsUntilExpired flaky - removed-cluster retention expiry cannot be tested deterministically
Dale Lane (Jira)
-
Re: [PR] [FLINK-39764] Support dynamic table options in Table API [flink]
via GitHub
-
[jira] [Updated] (FLINK-23758) PyFlink __invert__ has wrong semantics
ASF GitHub Bot (Jira)
-
[PR] [runtime] Do not retry or persist interrupted tool calls on cancellation [flink-agents]
via GitHub
-
Re: [PR] [FLINK-39031][python] Build pyflink wheels for Python 3.13 [flink]
via GitHub
-
[jira] [Assigned] (FLINK-40620) SourceTopicIntegrityTest.testTopicIntegritySuccess flaky - asserts exact record counts against at-least-once sink
Sergey Nuyanzin (Jira)
-
[jira] [Assigned] (FLINK-40619) DynamicKafkaSourceReaderTest.testHandleSourceEventRetainsRemovedClusterOffsetsUntilExpired flaky - removed-cluster retention expiry cannot be tested deterministically
Sergey Nuyanzin (Jira)
-
[jira] [Commented] (FLINK-40603) Use hadoop 3.4.3 in case of java25
Sergey Nuyanzin (Jira)
-
Re: [I] [Feature] Introduce subagent framework and AGENT resource type [flink-agents]
via GitHub
-
[jira] [Created] (FLINK-40620) SourceTopicIntegrityTest.testTopicIntegritySuccess flaky - asserts exact record counts against at-least-once sink
Dale Lane (Jira)
-
[jira] [Created] (FLINK-40619) DynamicKafkaSourceReaderTest.testHandleSourceEventRetainsRemovedClusterOffsetsUntilExpired flaky - removed-cluster retention expiry cannot be tested deterministically
Dale Lane (Jira)
-
Re: [PR] [FLINK-39617] [runtime] Add batch aggregated subtask metrics endpoints [flink]
via GitHub
-
Re: [I] [Bug][runtime] Do not retry or persist interrupted chat calls during job cancellation [flink-agents]
via GitHub
-
[jira] [Closed] (FLINK-40423) Add Top-N support to DataFrame API
Dian Fu (Jira)
-
Re: [PR] [FLINK-40478][runtime-web] Log effective HistoryServer configuration at startup [flink]
via GitHub
-
[jira] [Commented] (FLINK-39989) flinksessionjob stuck on "Job Not Found" if jobmanager terminates before operator learns about new job state transitions
Han You (Jira)
-
Re: [PR] [api][plan][python][examples] Framework-managed LLM-as-judge routing (Strategies.llm) [flink-agents]
via GitHub
-
[jira] [Updated] (FLINK-40618) Connectors/Kafka: SourceTopicIntegrityTest.testTopicIntegritySuccess is flaky, times out waiting for records
Purushottam Sinha (Jira)
-
[jira] [Commented] (FLINK-40597) TypeExtractor rejects explicitly specified Types.UUID
dylanhz (Jira)
-
Re: [PR] [FLINK-39697] Support Flink 2.0.x and Pulsar Client 4.0.9 [flink-connector-pulsar]
via GitHub
-
[jira] [Updated] (FLINK-40598) Complete and synchronize the Chinese Elastic Scaling documentation
Zhe Wang (Jira)
-
[jira] [Commented] (FLINK-40197) Add sql bindings to DataFrame API
Federico Dolce (Jira)
-
[jira] [Created] (FLINK-40618) Connectors/Kafka: SourceTopicIntegrityTest.testTopicIntegritySuccess is flaky, times out waiting for records
Purushottam Sinha (Jira)
-
[PR] [FLINK-40197][python] Support UDF bindings in DataFrame sql() [flink]
via GitHub
-
[jira] [Comment Edited] (FLINK-40580) Render VARIANT object/array as SQL when casting to character string
Timo Walther (Jira)
-
Re: [D] Community Sync - 2026 [flink-agents]
via GitHub
-
[jira] [Created] (FLINK-40611) Add Python UDF type inference to aggregate & table aggregate UDFs
Mika Naylor (Jira)
-
[jira] [Created] (FLINK-40617) Connectors/Kafka: Bump jackson-bom, log4j, avro, and other dependency versions
Purushottam Sinha (Jira)
-
[jira] [Updated] (FLINK-40617) Connectors/Kafka: Bump jackson-bom, log4j, avro, and other dependency versions
Purushottam Sinha (Jira)
-
[jira] [Created] (FLINK-40616) Make BITMAP and VARIANT conversion handling consistent and remove redundant checks
Ramin Gharib (Jira)
-
[jira] [Resolved] (FLINK-40572) Support dynamic model selection for AI functions
Xiqian Yu (Jira)
-
[PR] [hotfix] Bump jackson-bom, log4j, avro [flink-connector-kafka]
via GitHub
-
Re: [PR] [FLINK-40617] Bump jackson-bom, log4j, avro, commons, archunit, docker-java-api, guava, javassist, objenesis, snakeyaml, snappy-java [flink-connector-kafka]
via GitHub
-
Re: [PR] [FLINK-40617][build] Prune and bump dependency versions in the root pom [flink-connector-kafka]
via GitHub
-
Re: [PR] [FLINK-40617][build] Prune and bump dependency versions in the root pom [flink-connector-kafka]
via GitHub
-
Re: [PR] [FLINK-40617][build] Prune and bump dependency versions in the root pom [flink-connector-kafka]
via GitHub
-
[jira] [Assigned] (FLINK-40599) Allow pyarrow 21-25 (CVE-2026-25087)
Dian Fu (Jira)
-
[jira] [Updated] (FLINK-40615) KafkaSourceEnumerator assigns duplicate splits when partition discovery interval is shorter than split initialization time
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40615][Connectors/Kafka] Fix duplicate partition assignment in KafkaSourceEnumerator [flink-connector-kafka]
via GitHub
-
[jira] [Created] (FLINK-40615) KafkaSourceEnumerator assigns duplicate splits when partition discovery interval is shorter than split initialization time
Sylwester Lachiewicz (Jira)
-
[jira] [Closed] (FLINK-40599) Allow pyarrow 21-25 (CVE-2026-25087)
Dian Fu (Jira)
-
Re: [PR] [FLINK-39330][runtime] Make CollectSinkFunction teardown null-safe to fix flaky FileSourceTextLinesITCase JM failover [flink]
via GitHub
-
Re: [PR] [FLINK-40421][python] Add sorting APIs to DataFrame API [flink]
via GitHub
-
Re: [I] [Question] Does the chat-model retry budget intentionally reset across job restarts? [flink-agents]
via GitHub
-
[PR] [FLINK-40576][fs] Exclude transitive alluxio dependency from flink-s3-fs-presto [flink]
via GitHub