Messages by Thread
-
[PR] [integrations][java][python] Preserve Watsonx finish_reason in extra_args [flink-agents]
via GitHub
-
[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
-
[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
-
[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] (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)
-
[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
-
[jira] [Updated] (FLINK-40618) Connectors/Kafka: Run SourceTopicIntegrity test in the integration-test phase
Purushottam Sinha (Jira)
-
[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
-
[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)
-
[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
-
[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)
-
[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)
-
[jira] [Closed] (FLINK-40423) Add Top-N support to DataFrame API
Dian Fu (Jira)
-
[jira] [Commented] (FLINK-39989) flinksessionjob stuck on "Job Not Found" if jobmanager terminates before operator learns about new job state transitions
Han You (Jira)
-
[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)
-
[jira] [Updated] (FLINK-40598) Complete and synchronize the Chinese Elastic Scaling documentation
Zhe Wang (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)
-
[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
-
[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
-
[PR] [FLINK-40576][fs] Exclude transitive alluxio dependency from flink-s3-fs-presto [flink]
via GitHub
-
[jira] [Created] (FLINK-40608) Extract dataframe UDF type inference into shared module
Mika Naylor (Jira)
-
Re: [PR] [FLINK-40362][connector/kafka] Fix idle reader hang when no-more-splits precedes metadata update [flink-connector-kafka]
via GitHub
-
Re: [PR] [FLINK-40136][Connectors/Kafka] Fix flaky ConcurrentModificationException in DynamicKafkaSourceEnumeratorTest [flink-connector-kafka]
via GitHub
-
Re: [PR] [FLINK-40137][Connectors/Kafka] Extract ReaderRecoveryGate from DynamicKafkaSourceEnumerator [flink-connector-kafka]
via GitHub
-
[jira] [Assigned] (FLINK-40427) Add catalog management and catalog table I/O to DataFrame API
Dian Fu (Jira)
-
[PR] [FLINK-40606][table-planner] Fix code generation for binary array casts [flink]
via GitHub
-
[jira] [Resolved] (FLINK-40603) Use hadoop 3.4.3 in case of java25
Sergey Nuyanzin (Jira)
-
[jira] [Created] (FLINK-40609) Add composite/ROW inference in Python UDF type inference
Mika Naylor (Jira)
-
[jira] [Created] (FLINK-40612) Add phantom type overrides to Python UDF type inference
Mika Naylor (Jira)
-
[jira] [Created] (FLINK-40614) Add documentation for Python UDF type inference
Mika Naylor (Jira)
-
[jira] [Created] (FLINK-40613) Add Union & Any input types to Python UDF type inference
Mika Naylor (Jira)
-
[jira] [Created] (FLINK-40610) Add Python UDF type inference to scalar & table UDFs
Mika Naylor (Jira)
-
[jira] [Created] (FLINK-40607) Introduce Type Inference for Python User Defined Functions
Mika Naylor (Jira)
-
Re: [PR] [FLINK-40073] [INFRA] Add delete and force push protection to default and release branches [flink]
via GitHub
-
[jira] [Closed] (FLINK-40580) Render VARIANT object/array as SQL when casting to character string
Timo Walther (Jira)
-
[jira] [Updated] (FLINK-40580) Render VARIANT object/array as SQL when casting to character string
Timo Walther (Jira)
-
[I] [Feature] [Improvement][runtime] Replace isDone() polling with completion-callback wakeup for suspended Java async actions [flink-agents]
via GitHub
-
[jira] [Updated] (FLINK-40576) Exclude the transitive alluxio dependency from flink-s3-fs-presto
ASF GitHub Bot (Jira)
-
[jira] [Commented] (FLINK-40427) Add catalog management and catalog table I/O to DataFrame API
Federico Dolce (Jira)
-
[jira] [Updated] (FLINK-40606) Casting binary arrays generates invalid Java array allocation
ASF GitHub Bot (Jira)
-
[PR] Bump vitest from 4.1.10 to 4.1.11 in /flink-runtime-web/web-dashboard [flink]
via GitHub
-
Re: [PR] [FLINK-XXXXX][table] Refactor changelog inference program [flink]
via GitHub
-
Re: [PR] [FLINK-39615] [docs] Translate changelog.md documentation to Chinese [flink]
via GitHub
-
[jira] [Created] (FLINK-40606) Casting binary arrays generates invalid Java array allocation
dylanhz (Jira)
-
Re: [PR] [FLINK-34806][postgres] Expose scan.newly-added-table.enabled option [flink-cdc]
via GitHub
-
[jira] [Closed] (FLINK-40430) Add configuration support to DataFrame API
Dian Fu (Jira)
-
Re: [PR] [FLINK-40203][runtime] Add an explicit option for Flink SQL-compatible YAML Transform expression semantics [flink-cdc]
via GitHub
-
[jira] [Updated] (FLINK-40605) Code splitting still exceeds 64 KB for large if blocks containing loops with break or continue
ASF GitHub Bot (Jira)
-
[jira] [Created] (FLINK-40605) Code splitting still exceeds 64 KB for large if blocks containing loops with break or continue
Moses (Jira)
-
[PR] [table-code-splitter] Allow splitting if blocks containing loops with jump statements [flink]
via GitHub
-
[jira] [Created] (FLINK-40604) AsyncWaitOperator bypasses timeout handler when retry result mail runs after the deadline
David Peacock (Jira)
-
[PR] [BP-2.2][FLINK-40596] Closing metric might lead to a number of test failures [flink]
via GitHub
-
[PR] [FLINK-40601][runtime-web] Add Vitest specs for remaining web dashboard views [flink]
via GitHub
-
[jira] [Updated] (FLINK-40601) Web dashboard: finish Vitest coverage for core services and job-detail drawer
ASF GitHub Bot (Jira)
-
[PR] [BP-2.3][FLINK-40596] Closing metric might lead to a number of test failures [flink]
via GitHub
-
[jira] [Updated] (FLINK-40603) Use hadoop 3.4.3 in case of java25
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40603][build] Use hadoop 3.4.3 for jdk25 [flink]
via GitHub
-
[jira] [Created] (FLINK-40603) Use hadoop 3.4.3 in case of java25
Sergey Nuyanzin (Jira)
-
[jira] [Updated] (FLINK-40602) JobManager silently omits running jobs whose JobMaster fails or times out on GET /jobs/overview
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40602][runtime] JobManager silently omits running jobs whose JobMaster fails or times out on GET /jobs/overview [flink]
via GitHub
-
[jira] [Created] (FLINK-40602) JobManager silently omits running jobs whose JobMaster fails or times out on GET /jobs/overview
Han You (Jira)
-
[jira] [Assigned] (FLINK-16165) NestedLoopJoin fallback to HashJoin when build records number is very large
Bonnie Varghese (Jira)
-
[jira] [Resolved] (FLINK-40399) Separate the SavepointKeyFilter runtime contract from push-down planning
Gabor Somogyi (Jira)
-
[jira] [Commented] (FLINK-40567) HistoryServerArchiveFetcherTest.testLazyFetchArchiveProactively is flaky on @TempDir cleanup
Robert Metzger (Jira)
-
[jira] [Created] (FLINK-40601) Web dashboard: finish Vitest coverage for core services and job-detail drawer
Purushottam Sinha (Jira)
-
[jira] [Assigned] (FLINK-40567) HistoryServerArchiveFetcherTest.testLazyFetchArchiveProactively is flaky on @TempDir cleanup
Robert Metzger (Jira)
-
[PR] [FLINK-40600][runtime-web] Add missing web dashboard specs and tighten thin ones [flink]
via GitHub
-
[jira] [Commented] (FLINK-16165) NestedLoopJoin fallback to HashJoin when build records number is very large
Bonnie Varghese (Jira)
-
[jira] [Comment Edited] (FLINK-16165) NestedLoopJoin fallback to HashJoin when build records number is very large
Bonnie Varghese (Jira)
-
Re: [PR] [FLINK-33045] Make it possible to disable auto-registering schema in Schema Registry [flink]
via GitHub
-
[jira] [Created] (FLINK-40600) Web dashboard: finish Vitest smoke-test coverage and tighten thin specs
Martijn Visser (Jira)
-
[jira] [Updated] (FLINK-40600) Web dashboard: finish Vitest smoke-test coverage and tighten thin specs
Martijn Visser (Jira)
-
[jira] [Assigned] (FLINK-40117) Web dashboard: extend Vitest smoke-test coverage to remaining high-traffic views
Martijn Visser (Jira)
-
[jira] [Resolved] (FLINK-40117) Web dashboard: extend Vitest smoke-test coverage to remaining high-traffic views
Martijn Visser (Jira)
-
Re: [PR] [FLINK-40117][runtime-web] Extend Vitest smoke-test coverage to more web-dashboard views [flink]
via GitHub