dev  

Messages by Thread

• [jira] [Created] (FLINK-40721) Add maven 3.9.16 to ci docker Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40720) Do not checkout all branches in ci Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40719) Free disk space silently fails with E: Unable to locate package hhvm Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40717) Create AGENTS.md for Flink MongoDB connector and update the PR description to track AI usage Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40718) Do not run weekly if there is no new commits since the last green run Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40716) [FileSystem] common filesystems interfaces for hadoop-less implementations Aleksandr Iushmanov (Jira)
• [jira] [Created] (FLINK-40715) FLIP-597 [FileSystems] Support common implementation for SDK native hadoop-less file systems Aleksandr Iushmanov (Jira)
• [jira] [Created] (FLINK-40713) Bump mongo-driver version from 5.1.1 to 5.11.1 to fix CVE-2026-88033 Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40712) Update dependencies in the Flink Connector MongoDB Project Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40714) Add MongoDB 8.0 to the multi-version integration test matrix Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40711) Don not run weekly if there is no new commits since the last green runs Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40710) Dynamic Kafka Source assigns duplicate partition owners after local failover Bowen Li (Jira)
• [jira] [Created] (FLINK-40709) Kubernetes Operator: allowlist to exempt trusted hosts from jarURI restricted-host check Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40707) Backports of FLINK-39572 breaks previous releases because of different Beam version Martijn Visser (Jira)
• [jira] [Created] (FLINK-40708) Support ValueView in PTFs Timo Walther (Jira)
• [jira] [Created] (FLINK-40706) Harden address validation in kubernetes operator artifact fetcher Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40705) PyFlink pandas UDFs fail on MAP inputs across Arrow batches Liu Liu (Jira)
• [DISCUSS] FLIP-608: Flink on Ray, Ray Resource Backend For Flink Zhanghao Chen
• [jira] [Created] (FLINK-40704) Enable spotless for java25 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40703) Improve correctness coverage: Add ITCase for recovery from a checkpoint whose pooled transactional id was reused by a later checkpoint Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40694) INSERT INTO with a column list fails over a process table function with a set-semantic table argument Martijn Visser (Jira)
• [jira] [Created] (FLINK-40702) Unify shared HTTP sink and lookup configuration options Bharath Reddy Gunapati (Jira)
• [jira] [Created] (FLINK-40701) Upgrade ArchUnit to 1.5.0 Martijn Visser (Jira)
• [jira] [Created] (FLINK-40700) Add typed DataStream configuration for HTTP sink options Bharath Reddy Gunapati (Jira)
• [jira] [Created] (FLINK-40699) Add HTTP sink continue-on-error and optional error/DLQ handling Bharath Reddy Gunapati (Jira)
• [jira] [Created] (FLINK-40698) Bump japicmp-maven-plugin to 0.26.2 Martijn Visser (Jira)
• [DISCUSS] Operator 1.16.1 patch release due to serious bug with observed runtime config feature Gyula Fóra
  • Re: [DISCUSS] Operator 1.16.1 patch release due to serious bug with observed runtime config feature Dennis-Mircea Ciupitu
  • Re: [DISCUSS] Operator 1.16.1 patch release due to serious bug with observed runtime config feature Robert Metzger
  • Re: [DISCUSS] Operator 1.16.1 patch release due to serious bug with observed runtime config feature P Sinha
• [jira] [Created] (FLINK-40697) Release finished snapshot split metadata in the incremental source framework (flink-cdc-base) Spoorthi Basu (Jira)
• [VOTE] Apache Flink Kubernetes Operator Release 1.16.1, release candidate #1 Gyula Fóra
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.16.1, release candidate #1 P Sinha
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.16.1, release candidate #1 Dennis-Mircea Ciupitu
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.16.1, release candidate #1 Rui Fan
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.16.1, release candidate #1 Robert Metzger
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.16.1, release candidate #1 Gyula Fóra
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.16.1, release candidate #1 Gyula Fóra
• [jira] [Created] (FLINK-40696) Revert observed runtime config logic Gyula Fora (Jira)
• [jira] [Created] (FLINK-40695) Transient issues during ExecutionGraph creation lead to terminal job Failure Ahmed Hamdy (Jira)
• [REMINDER] Flink 2.4 Release Sync - 18.09.26 Chanhae Oh
• [jira] [Created] (FLINK-40693) FLOAT/DOUBLE IN and NOT IN disagree with equality for signed zero Sergey Paryshev (Jira)
• [jira] [Created] (FLINK-40692) [Model] Use default model version from server when no version is defined in model config Danish (Jira)
• [jira] [Created] (FLINK-40691) Fix comparison logic for binlog filename with more than 6 digits Yanquan Lv (Jira)
• [jira] [Created] (FLINK-40690) Fluss sink applies top-level column mapping to nested ROW fields Xiaobing Fang (Jira)
• [jira] [Created] (FLINK-40689) Kafka sink checkpoint recovery fails after producer epoch rollover with transaction V2 Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40687) flink-model shade relocations do not match, okhttp and kotlin ship unrelocated Martijn Visser (Jira)
• [jira] [Created] (FLINK-40688) flink-model-openai NOTICE lists httpcomponents artifacts it no longer bundles Martijn Visser (Jira)
• [jira] [Created] (FLINK-40686) Shaded jars declare a bundled dependency's JPMS module name Martijn Visser (Jira)
• [jira] [Created] (FLINK-40685) ForSt skips local cache cleanup for checkpoint-owned files Aaron He (Jira)
• [jira] [Created] (FLINK-40684) Tensor names are unconditionally uppercased Danish (Jira)
• [jira] [Created] (FLINK-40683) JoinSemanticTests[anti-join-on-nested] asserts the raw changelog on release-2.3 and release-2.2 Martijn Visser (Jira)
• [jira] [Created] (FLINK-40682) ArchivedExecutionGraphTest fails in setup with "BUG: trying to schedule a region which is not in CREATED state" sepuri sai krishna (Jira)
• [jira] [Created] (FLINK-40681) Streaming outer join drops the null-padded row after an inner-side update followed by delete when UPDATE_BEFORE is not required Martijn Visser (Jira)
• [jira] [Created] (FLINK-40680) Bump openai-java dependency Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40679) Support Iceberg table maintenance Mingliang Zhu (Jira)
• [VOTE] FLIP-611: Running Flink jobs in MiniCluster using the Kubernetes Operator Dale Lane
  • Re: [VOTE] FLIP-611: Running Flink jobs in MiniCluster using the Kubernetes Operator P Sinha
  • Re: [VOTE] FLIP-611: Running Flink jobs in MiniCluster using the Kubernetes Operator Dennis-Mircea Ciupitu
  • Re: [VOTE] FLIP-611: Running Flink jobs in MiniCluster using the Kubernetes Operator Zhanghao Chen
  • Re: [VOTE] FLIP-611: Running Flink jobs in MiniCluster using the Kubernetes Operator Robert Metzger
  • Re: [VOTE] FLIP-611: Running Flink jobs in MiniCluster using the Kubernetes Operator Dale Lane via dev
  • Re: [VOTE] FLIP-611: Running Flink jobs in MiniCluster using the Kubernetes Operator Gyula Fóra
  • Re: [VOTE] FLIP-611: Running Flink jobs in MiniCluster using the Kubernetes Operator Rui Fan
  • [VOTE] FLIP-611: Running Flink jobs in MiniCluster using the Kubernetes Operator Dale Lane via dev
• [jira] [Created] (FLINK-40678) Lookup join digest ignores table OPTIONS hints Martijn Visser (Jira)
• [jira] [Created] (FLINK-40677) Native application submission without jarURI fails in bundled Flink client David Peacock (Jira)
• [jira] [Created] (FLINK-40672) Incorrect nullability for CAST from VARIANT dylanhz (Jira)
• [jira] [Created] (FLINK-40676) Support Flink 2.0.x and Pulsar Client 4.0.9 Ferenc Csaky (Jira)
• Hackathon at Community over Code Glasgow — schedule slot needed Rich Bowen
  • Re: Hackathon at Community over Code Glasgow — schedule slot needed Andrea Cosentino
• [jira] [Created] (FLINK-40675) SqlGatewayServiceITCase.testReleaseLockWhenFailedToSubmitOperation is unstable sepuri sai krishna (Jira)
• [jira] [Created] (FLINK-40674) Stop deserializing SerializedThrowable via ObjectInputStream on parse Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-40673) INTERSECT ALL and EXCEPT ALL fail with mixed INT/BIGINT inputs Bettle (Jira)
• [jira] [Created] (FLINK-40671) Document why UnknownInputChannel graduation hardcodes needsRecovery=false Rui Fan (Jira)
• [jira] [Created] (FLINK-40669) Java 11 E2E group 2 on release-2.3 is killed at the 234 minute budget while the other profiles finish in half the time Martijn Visser (Jira)
• [jira] [Created] (FLINK-40670) MultiJoinSemanticTests[four-way-mixed-join-multi-key-types-shuffled] loses a row on release-2.3 Martijn Visser (Jira)
• [jira] [Created] (FLINK-40668) Document why the recovery drain cannot stall on zero-credit needsRecovery channels Rui Fan (Jira)
• [jira] [Created] (FLINK-40667) Buffer ref-count leaks in CDR recovery filtering end in free() on a live segment Rui Fan (Jira)
• [jira] [Created] (FLINK-40666) Simplify SNAPSHOT function by removing 'load_completed_condition' parameter Fabian Hueske (Jira)
• FLIP-608: Flink on Ray — Ray Resource Backend For Flink Zhanghao Chen
  • Re: FLIP-608: Flink on Ray — Ray Resource Backend For Flink Zhanghao Chen
• [jira] [Created] (FLINK-40665) cron_snapshot_deployment_maven fails the Maven version enforcer because deploy_staging_jars.sh uses the Maven on PATH Martijn Visser (Jira)
• [jira] [Created] (FLINK-40662) 'Run kubernetes Materialized Table test' fails on release-2.3 because the SQL Gateway returns a null session handle Martijn Visser (Jira)
• [jira] [Created] (FLINK-40664) JobIDLoggingITCase.testJobIDLogging fails on a "Freeing inactive slots" log line without the job id Martijn Visser (Jira)
• [jira] [Created] (FLINK-40663) WindowDistinctAggregateStressITCase.testCumulateWindowRollupUnderBackpressure times out after 600s Martijn Visser (Jira)
• [jira] [Created] (FLINK-40661) Kerberized and PyFlink YARN Docker e2e tests fail on release-1.20 because the KDC image is built from debian:bullseye Martijn Visser (Jira)
• [RESULT] [VOTE] Apache Flink Kubernetes Operator Release 1.16.0, release candidate #3 Gyula Fóra
• [jira] [Created] (FLINK-40660) SplitFetcher hangs on shutdown when its element queue wakeUp flag is still set Martijn Visser (Jira)
• [jira] [Created] (FLINK-40659) SingleThreadFetcherManager reaps and recreates its fetcher on every idle gap Martijn Visser (Jira)
• [jira] [Created] (FLINK-40658) UNNEST silently drops null ROW elements from ARRAY Bettle (Jira)
• [jira] [Created] (FLINK-40651) Support configurable Iceberg file rolling within a checkpoint Yanquan Lv (Jira)
• [jira] [Created] (FLINK-40656) Distributed schema coordinator can remain EVOLVING after checkpoint restore Xiaobing Fang (Jira)
• [jira] [Created] (FLINK-40657) FutureCompletingBlockingQueue retains a ConditionAndFlag for every SplitFetcher ever created Alexandru (Jira)
• [VOTE] FLIP-607: Migrate Flink off end-of-life OkHttp; keep it off the core classpath Martijn Visser
  • Re: [VOTE] FLIP-607: Migrate Flink off end-of-life OkHttp; keep it off the core classpath P Sinha
  • Re: [VOTE] FLIP-607: Migrate Flink off end-of-life OkHttp; keep it off the core classpath Gustavo de Morais
  • Re: [VOTE] FLIP-607: Migrate Flink off end-of-life OkHttp; keep it off the core classpath Efrat Levitan
  • Re: [VOTE] FLIP-607: Migrate Flink off end-of-life OkHttp; keep it off the core classpath Zhe Wang
  • Re: [VOTE] FLIP-607: Migrate Flink off end-of-life OkHttp; keep it off the core classpath Samrat Deb
  • Re: [VOTE] FLIP-607: Migrate Flink off end-of-life OkHttp; keep it off the core classpath Ferenc Csaky
  • Re: [VOTE] FLIP-607: Migrate Flink off end-of-life OkHttp; keep it off the core classpath Sergey Nuyanzin
  • Re: [VOTE] FLIP-607: Migrate Flink off end-of-life OkHttp; keep it off the core classpath Martijn Visser
• [jira] [Created] (FLINK-40654) cron_snapshot_deployment jobs fail because build-nightly-dist.yml still points at tools/azure-pipelines/free_disk_space.sh Martijn Visser (Jira)
• [jira] [Created] (FLINK-40653) Testcontainers tests fail with "Could not find a valid Docker environment" on the cron_azure profile Martijn Visser (Jira)
• [jira] [Created] (FLINK-40655) ExecutionVertexTest.testResetForNewExecutionReleasesPartitions is unstable Martijn Visser (Jira)
• [jira] [Created] (FLINK-40652) MinioTestContainerTest and the S3 e2e tests fail on all release branches because minio/minio was removed from Docker Hub Martijn Visser (Jira)
• [jira] [Created] (FLINK-40650) Improve SqlServerDialect.discoverDataCollectionSchemas to reduce snapshot start time with many tables Stefano Franco (Jira)
• [jira] [Created] (FLINK-40649) [sqlserver-cdc] Agent status validation fails on localized SQL Server instances where service name is not in English dulele (Jira)
• [jira] [Created] (FLINK-40648) PrometheusReporter drops all metrics of a process when two metric group variables sanitise to the same label name Martijn Visser (Jira)
• [jira] [Created] (FLINK-40647) Support best-effort schema expansion for existing sink tables during table creation Mao Jiayi (Jira)
• [jira] [Created] (FLINK-40646) [Postgres CDC] Pooled JDBC connections use the default application name Hongshun Wang (Jira)
• [jira] [Created] (FLINK-40645) ForSt file cache: closed CachedDataInputStreams stay registered in FileCacheEntry.openedStreams until the file is evicted, accumulating on the heap seungjoo choi (Jira)
• [jira] [Created] (FLINK-40644) ForSt file cache: CachedDataInputStream.close() does not close the remote (original) stream, leaking S3A connections until the pool is exhausted seungjoo choi (Jira)
• [PR] [FLINK-40643][ci] Combine download and untar runs to decrease image size [flink-ci-docker] via GitHub
  • Re: [PR] [FLINK-40643][ci] Combine download and untar runs to decrease image size [flink-ci-docker] via GitHub
• [jira] [Created] (FLINK-40643) Do not use dowload/untar runs separately in flink-ci-docker Sergey Nuyanzin (Jira)
• [PR] [FLINK-40642] Flink CI docker build fails on Mac [flink-ci-docker] via GitHub
  • Re: [PR] [FLINK-40642] Flink CI docker build fails on Mac [flink-ci-docker] via GitHub
• [jira] [Created] (FLINK-40642) Flink ci docker build fails on Mac Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40641) Cover the Prometheus reporter exposition contract Martijn Visser (Jira)
• [jira] [Created] (FLINK-40640) [Iceberg] UPDATE that changes a partitioned column's value leaves a duplicate stale row in the old partition VISHAL B (Jira)
• [jira] [Created] (FLINK-40639) Deprecated kubernetes.pod-template-file takes precedence over kubernetes.pod-template-file.default sepuri sai krishna (Jira)
• [DISCUSS] Review request for FLINK-40508: Support DB2 pipeline connector Jagger
  • Re: [DISCUSS] Review request for FLINK-40508: Support DB2 pipeline connector Leonard Xu
• [DISCUSS] Remove Deprecated Configuration Options/Keys in Flink Yuepeng Pan
  • Re: [DISCUSS] Remove Deprecated Configuration Options/Keys in Flink Rui Fan
  • Re: [DISCUSS] Remove Deprecated Configuration Options/Keys in Flink Krishna Sai
  • Re: [DISCUSS] Remove Deprecated Configuration Options/Keys in Flink Yuepeng Pan
  • Re: [DISCUSS] Remove Deprecated Configuration Options/Keys in Flink Krishna Sai
  • Re: [DISCUSS] Remove Deprecated Configuration Options/Keys in Flink Yuepeng Pan
  • Re: [DISCUSS] Remove Deprecated Configuration Options/Keys in Flink Krishna Sai
  • Re: [DISCUSS] Remove Deprecated Configuration Options/Keys in Flink Yuepeng Pan
  • Re: [DISCUSS] Remove Deprecated Configuration Options/Keys in Flink Krishna Sai
  • Re: [DISCUSS] Remove Deprecated Configuration Options/Keys in Flink Yuepeng Pan
• [jira] [Created] (FLINK-40638) Add optional custom URL handlers for JobManager and TaskManager logs in the history server Archit Goyal (Jira)
• [ANNOUNCE] Lakehouse Day EU 2026 Danica Fine
• [DISCUSS] Session context for catalog view creation Talat Uyarer via dev
• [jira] [Created] (FLINK-40637) Catalog view expansion falls back to the session database for unresolved references Talat Uyarer (Jira)
• [jira] [Created] (FLINK-40636) Add Maven/Aether connection timeouts to shared connector CI to avoid 50-minute hangs Sylwester Lachiewicz (Jira)
• [jira] [Created] (FLINK-40635) Test CalcRestoreTest>RestoreTestBase.testRestore failing Samrat Deb (Jira)
• [DISCUSS] FLIP-612: Native XML Functions for Flink SQL Moritz Manner
  • Re: [DISCUSS] FLIP-612: Native XML Functions for Flink SQL Timo Walther
  • Re: [DISCUSS] FLIP-612: Native XML Functions for Flink SQL Fabian Hüske via dev
  • Re: [DISCUSS] FLIP-612: Native XML Functions for Flink SQL Moritz Manner
  • Re: [DISCUSS] FLIP-612: Native XML Functions for Flink SQL Krishna Sai
  • Re: [DISCUSS] FLIP-612: Native XML Functions for Flink SQL Fabian Hüske via dev
  • Re: [DISCUSS] FLIP-612: Native XML Functions for Flink SQL Timo Walther
  • Re: [DISCUSS] FLIP-612: Native XML Functions for Flink SQL Moritz Manner
  • Re: [DISCUSS] FLIP-612: Native XML Functions for Flink SQL Krishna Sai
  • Re: [DISCUSS] FLIP-612: Native XML Functions for Flink SQL Timo Walther
  • Re: [DISCUSS] FLIP-612: Native XML Functions for Flink SQL Moritz Manner
  • Re: [DISCUSS] FLIP-612: Native XML Functions for Flink SQL Timo Walther
• [jira] [Created] (FLINK-40632) Remove Experimental Annotation of Native S3 Samrat Deb (Jira)
• [jira] [Created] (FLINK-40634) E2E are extremely slow in Azure Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40633) Make download-crt-jars.sh maven command agnostic Gabor Somogyi (Jira)
• Review request for FLINK-40592 / PR #29151 纪伟成
• [DISCUSS] Closing 84 stale Connectors/Kafka JIRA issues about removed APIs Sylwester Lachiewicz
• [jira] [Created] (FLINK-40631) table-planner: CalcRestoreTest calc-variant restore fails after Variant type evolution (serialVersionUID) Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40630) Use Apache Parent POM 39 in flink-connector-parent Martijn Visser (Jira)
• [jira] [Created] (FLINK-40629) Bump the build/enforced Maven version from 3.8.6 to 3.9.16 in flink-connector-kafka Martijn Visser (Jira)
• [jira] [Created] (FLINK-40628) PyFlink TTL initialization can hang task threads and leave jobs stuck in INITIALIZING Bowen Li (Jira)
• [jira] [Created] (FLINK-40625) Create AGENTS.md for Flink Kafka connector and update the PR description to track AI usage Martijn Visser (Jira)
• [DISCUSS] FLINK-40234: which layer should stop busy subtask time from marking source splits idle? Sylwester Lachiewicz
  • Re: [DISCUSS] FLINK-40234: which layer should stop busy subtask time from marking source splits idle? Roman Khachatryan
  • Re: Re: [DISCUSS] FLINK-40234: which layer should stop busy subtask time from marking source splits idle? Sylwester Lachiewicz
• [jira] [Created] (FLINK-40627) Partially fetched user artifacts are reused on subsequent starts Dale Lane (Jira)
• [jira] [Created] (FLINK-40626) KafkaCommitter leaves the newer open transaction under a reused transactional id after a fenced commit Sylwester Lachiewicz (Jira)
• [jira] [Created] (FLINK-40624) KafkaCommitter and ExactlyOnceKafkaWriter do not handle InvalidProducerEpochException alongside ProducerFencedException Sylwester Lachiewicz (Jira)
• [jira] [Created] (FLINK-40621) FlinkKafkaInternalProducerITCase.testResetInnerTransactionIfFinalizingTransactionFailed fails with InvalidProducerEpochException instead of ProducerFencedException Martijn Visser (Jira)
• [jira] [Created] (FLINK-40623) [cdc-base] JdbcSourceChunkSplitter keeps a pooled JDBC connection for the whole job lifetime; with default connection.pool.size=20 the 21st incremental-snapshot job on the same JobManager can never start wglbd12 (Jira)
• [jira] [Created] (FLINK-40622) SourceTopicIntegrityTest.testTopicIntegrityFailure times out waiting for the job to fail with "Topic ... is missing" Martijn Visser (Jira)
• [Flink CDC][postgres] JobManager connection pool exhausted after 20 incremental-snapshot jobs: JdbcSourceChunkSplitter keeps a pooled JDBC connection for the whole job lifetime Kyrie
  • RE: [Flink CDC][postgres] JobManager connection pool exhausted after 20 incremental-snapshot jobs: JdbcSourceChunkSplitter keeps a pooled JDBC connection for the whole job lifetime Hongshun Wang
  • Re: [Flink CDC][postgres] JobManager connection pool exhausted after 20 incremental-snapshot jobs: JdbcSourceChunkSplitter keeps a pooled JDBC connection for the whole job lifetime Kyrie
• Issue in applying network policy as random ports in Jobmanager and Taskmanager are visible Taranpreet Kaur via dev
• [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] [Created] (FLINK-40618) Connectors/Kafka: SourceTopicIntegrityTest.testTopicIntegritySuccess is flaky, times out waiting for records Purushottam Sinha (Jira)
• [jira] [Created] (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] [Created] (FLINK-40615) KafkaSourceEnumerator assigns duplicate splits when partition discovery interval is shorter than split initialization time Sylwester Lachiewicz (Jira)
• [jira] [Created] (FLINK-40606) Casting binary arrays generates invalid Java array allocation dylanhz (Jira)
• [jira] [Created] (FLINK-40614) Add documentation for Python UDF type inference Mika Naylor (Jira)
• [jira] [Created] (FLINK-40611) Add Python UDF type inference to aggregate & table aggregate UDFs Mika Naylor (Jira)
• [jira] [Created] (FLINK-40613) Add Union & Any input types to Python UDF type inference Mika Naylor (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-40608) Extract dataframe UDF type inference into shared module 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)
• [RESULT][VOTE] FLIP-609: Type Inference for Python User Defined Functions Mika Naylor
• [jira] [Created] (FLINK-40605) Code splitting still exceeds 64 KB for large if blocks containing loops with break or continue Moses (Jira)
• [jira] [Created] (FLINK-40604) AsyncWaitOperator bypasses timeout handler when retry result mail runs after the deadline David Peacock (Jira)
• [jira] [Created] (FLINK-40603) Use hadoop 3.4.3 in case of java25 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40602) JobManager silently omits running jobs whose JobMaster fails or times out on GET /jobs/overview Han You (Jira)
• [jira] [Created] (FLINK-40601) Web dashboard: finish Vitest coverage for core services and job-detail drawer Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40600) Web dashboard: finish Vitest smoke-test coverage and tighten thin specs Martijn Visser (Jira)
• [jira] [Created] (FLINK-40596) Closing metric might lead to a number of test failure Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40599) Allow pyarrow 21-25 (CVE-2026-25087) Florian Vazelle (Jira)

• Earlier messages
• Later messages