issues  

Messages by Date

• 2026/10/30 [jira] [Updated] (FLINK-28061) create new tech blog for connector development based on Source API Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Commented] (FLINK-37719) Support Java 25 (LTS) Sumin Joo (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-27596) [Umbrella] Optimize Hive source Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-41281) Allow CAST from a VARIANT timestamp to the other temporal types ASF GitHub Bot (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-34453) [Benchmark] Add warmup in SchedulerBenchmarkExecutor Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-34974) FLIP-424: Asynchronous State APIs Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-30399) Enable connectors to use config docs generator Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-30379) Decouple connector docs integration from connector releases Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-26949) Add NVL supported in SQL & Table API Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-32577) Avoid memory fragmentation when running CI for flink-table-planner module Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-34607) Migrate BatchPhysicalUnionRule Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-33562) Externalize RabbitMQ Python connector code Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-36160) Support hive advanced configuration Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-35166) Improve the performance of Hybrid Shuffle when enable memory decoupling Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-39544) Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-32530) array_position semantic should align with array_contains instead of spark Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-32184) Use revision version property Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-34335) Query hints in RexSubQuery could not be printed Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-30290) IteratorSourceReaderBase should report END_OF_INPUT sooner Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-31336) interval type process has problem in table api and sql Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-32682) Introduce option for choosing time function evaluation methods Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-34191) Remove RestoreMode#LEGACY Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-28120) Meet assert error: BatchPhysicalExchange.BATCH_PHYSICAL has lower cost then best cost of subset :RelSubset#15.BATCH_PHYSICAL.hash[0, 1]true.[]] Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-33631) Remove HA ConfigMap label setup Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-31249) Checkpoint timeout mechanism fails when finalizeCheckpoint is stuck Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-30578) Publish SBOM artifacts Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-27242) Support RENAME PARTITION statement for partitioned table Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-32753) Print JVM flags on AZP Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-32682) Introduce option for choosing time function evaluation methods Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-30738) Disable verbose mode Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-33895) Implement restore tests for PythonGroupWindowAggregate node Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-32983) Support setting env.java.opts.all & env.java.opts.cli configs via dynamic properties on the CLI side Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-38463) Support TTL in SinkUpsertMaterializerV2 Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-33162) seperate the executor in DefaultDispatcherResourceManagerComponentFactory for MetricFetcher and webMonitorEndpoint Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-27809) Clarify that cluster-id is mandatory for Kubernetes HA in standalone mode Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-27858) Hive source support filter push down for parquet format Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-33819) Support setting CompressType in RocksDBStateBackend Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-26942) Support SELECT clause in CREATE TABLE(CTAS) Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-32427) FLIP-295: Support lazy initialization of catalogs and persistence of catalog configurations Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-41045) 'Running Kerberized YARN application on Docker test (custom fs plugin)' fails with NoResourceAvailableException because two of three TaskManager containers never register ASF GitHub Bot (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-33498) Do not allow manually triggering incremental checkpoints with full checkpoint configured Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-35012) ChangelogNormalizeRestoreTest.testRestore failure Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-23216) RM keeps allocating and freeing slots after a TM lost until its heartbeat timeout Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-33951) should use aggCallNeedRetractions instead of needRetraction to check retract method, orelse throw not implement retract method Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-26253) Speed up detection of dropped message in MessageSerializationTest Yuepeng Pan (Jira)
• 2026/10/30 Re: [PR] [FLINK-40129][Connectors/Kafka] Topic integrity check in table API [flink-connector-kafka] Savonitar (via GitHub) via issues
• 2026/10/30 [jira] [Updated] (FLINK-34610) Migrate StreamPhysicalLimitRule Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-41049) CI jobs fail when the downloaded Maven wrapper jar does not pass its SHA-256 check Sergey Nuyanzin (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-15729) Table planner dependency instructions for executing in IDE can be improved Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Commented] (FLINK-41049) CI jobs fail when the downloaded Maven wrapper jar does not pass its SHA-256 check Sergey Nuyanzin (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-38223) ExecutionGraphRestartTest and ExecutionGraphCoLocationRestartTest are flaky on master Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-38459) SinkUpsertMaterializer V2 (FLIP-544) Yuepeng Pan (Jira)
• 2026/10/30 [PR] [FLINK-41033][operator] Keep upgradeSavepointPath at the newest compl… [flink-kubernetes-operator] via GitHub
• 2026/10/30 [jira] [Updated] (FLINK-32530) array_position semantic should align with array_contains instead of spark Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-23855) Table API & SQL Configuration Not displayed on flink dashboard Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-16531) Add full integration tests for "GROUPING SETS" for streaming mode Yuepeng Pan (Jira)
• 2026/10/30 Re: [PR] [BP-1.20][FLINK-41117][ci] Bump ubuntu to 26 in Azure and GHA [flink] flinkbot (via GitHub) via issues
• 2026/10/30 Re: [PR] [BP-2.2][FLINK-41117][ci] Bump ubuntu to 26 in Azure and GHA [flink] flinkbot (via GitHub) via issues
• 2026/10/30 [jira] [Updated] (FLINK-20484) Improve hive temporal table exception Yuepeng Pan (Jira)
• 2026/10/30 Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
• 2026/10/30 [jira] [Updated] (FLINK-35206) Desc table syntax support materialized table Yuepeng Pan (Jira)
• 2026/10/30 [PR] [BP-1.20][FLINK-41117][ci] Bump ubuntu to 26 in Azure and GHA [flink] snuyanzin (via GitHub) via issues
• 2026/10/30 [jira] [Updated] (FLINK-16077) Translate "Custom State Serialization" page into Chinese Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-16548) Expose consistent environment variable to identify the component name and resource id of jm/tm Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-37836) FLIP-486 Introduce a new DeltaJoin Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-34611) Migrate StreamPhysicalUnionRule Yuepeng Pan (Jira)
• 2026/10/30 Re: [PR] [BP-2.3][FLINK-41117][ci] Bump ubuntu to 26 in Azure and GHA [flink] flinkbot (via GitHub) via issues
• 2026/10/30 [jira] [Updated] (FLINK-18201) Support create_function in Python Table API Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-34650) Migrate PushProjectIntoLegacyTableSourceScanRule Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-19007) Automatically set presto staging directory to io.tmp.dirs Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-16548) Expose consistent environment variable to identify the component name and resource id of jm/tm Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-34973) FLIP-425: Asynchronous Execution Model Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-37431) We should use guava Lists instead of curator shade Lists to avoid unnecessary error Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-35573) [FLIP-447] Upgrade FRocksDB from 6.20.3 to 8.10.0 Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-28919) Add built-in generate_series function. Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-29003) sqlServerDialect should support limit clause Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-38570) FLIP-554: Pipeline Testing Framework for Flink Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-29060) can not set rewriteBatchedStatements parameter for JDBC catalog for MySQL Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-38595) Extend MultiJoin tests for further validation Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-29040) When using the JDBC Catalog, the custom cannot be applied because it is fixed in the code Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-35688) Add materialized table develop guide docs Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-19819) SourceReaderBase supports limit push down Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-35529) protobuf-format compatible protobuf bad indentifier Yuepeng Pan (Jira)
• 2026/10/30 [PR] [BP-2.2][FLINK-41117][ci] Bump ubuntu to 26 in Azure and GHA [flink] snuyanzin (via GitHub) via issues
• 2026/10/30 [jira] [Updated] (FLINK-35529) protobuf-format compatible protobuf bad indentifier Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-28764) Support more than 64 distinct aggregate function calls in one aggregate SQL query Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-35769) State files might not be deleted on task cancellation Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-36008) Guidance for previewing connector docs contributions Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-22960) Temporal join TTL should use enableTimeToLive of state instead of timer Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-23216) RM keeps allocating and freeing slots after a TM lost until its heartbeat timeout Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-26831) Move JarHandlers to flink-runtime Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-18592) StreamingFileSink fails due to truncating HDFS file failure Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-36046) Change the existing org.apache.flink.streaming.api.functions.sink#DiscardingSink and org.apache.flink.streaming.api.functions.sink#PrintSinkFunction to use the new interfaces Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-31267) Fine-Grained Resource Management supports table and sql levels Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-31116) Support taskmanager related parameters in session mode Support job granularity setting Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-31654) DataStreamUtils.reinterpretAsKeyedStream() should not override the user specified chaining strategy. Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-16126) Translate all connector related pages into Chinese Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-29723) Supports hive first_value function by native implementation Yuepeng Pan (Jira)
• 2026/10/30 [PR] [BP-2.3][FLINK-41117][ci] Bump ubuntu to 26 in Azure and GHA [flink] snuyanzin (via GitHub) via issues
• 2026/10/30 [jira] [Updated] (FLINK-20952) Changelog json formats should support inherit options from JSON format Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-35326) Implement lineage interface for hive connector Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-38120) FLIP-536 Add latest checkpoint details endpoint Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-37526) Promote SinkV2 API classes from @Experimental to @PublicEvolving Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-37777) FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-37551) Improve the state compatibility of ForStKeyeStateBackend and ForStSyncKeyeStateBackend Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-35534) Support profiler for benchmarks Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-39422) [FLINK][OpenAPI] OpenApiSpecGenerator produces incorrect schemas for types with custom Jackson serializers Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-38351) Docker images support OpenJDK Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Commented] (FLINK-40842) Streaming semi/anti join over-counts matches for right-side updates without UPDATE_BEFORE Sergey Nuyanzin (Jira) via issues
• 2026/10/30 [PR] [FLINK-41281][table] Allow CAST from a VARIANT timestamp to the other temporal types [flink] via GitHub
• 2026/10/30 [jira] [Updated] (FLINK-27632) Improve connector testing framework to support more cases Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-26664) Improve Python exception messages to be more Pythonic in PyFlink Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-31841) Redundant local variables in AllWindowedStream#reduce Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-34255) FLIP-406: Reorganize State & Checkpointing & Recovery Configuration Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8 Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-36381) Remove legacy csv source/sink in python module Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-28074) show statistics details for DESCRIBE EXTENDED Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-25900) Create view example does not assign alias to functions resulting in generated names like EXPR$5 Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-34129) MiniBatchGlobalGroupAggFunction will make -D as +I then make +I as -U when state expired Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-34004) TestingCheckpointIDCounter can easily lead to NPEs Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-33819) Support setting CompressType in RocksDBStateBackend Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-27593) Parquet/Orc format reader optimization Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-33120) FLIP-361: Improve GC Metrics Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-11409) Make `ProcessFunction`, `ProcessWindowFunction` and etc. pure interfaces Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-36291) java.lang.IllegalMonitorStateException causing a fatal error on the TaskManager side Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-30970) Fix SQL Client doc still uses old style output Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-40886) BlobLibraryCacheManagerTest.testApplicationLevelJarSharing fails with FileAlreadyExistsException on the application directory Martijn Visser (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-32239) Unify TestJvmProcess and TestProcessBuilder Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-41275) Start containers in e2e per class rather than per test in SQL e2e ASF GitHub Bot (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-30399) Enable connectors to use config docs generator Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-26968) Bump CopyOnWriteStateMap entry version before write Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-26761) Fix the cast exception thrown by PreValidateReWriter when insert into/overwrite a partitioned table. Yuepeng Pan (Jira)
• 2026/10/30 Re: [PR] [FLINK-41281][table] Allow CAST from a VARIANT timestamp to the other temporal types [flink] via GitHub
• 2026/10/30 [jira] [Updated] (FLINK-36849) Introduce AppendOnlyFirstNFunction in Rank with Async State API Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-23869) Correct javadoc of ExecutionConfig#registerKryoType Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-32427) FLIP-295: Support lazy initialization of catalogs and persistence of catalog configurations Yuepeng Pan (Jira)
• 2026/10/30 Re: [PR] [BP-2.4][FLINK-40958][core] `BinaryVariantInternalBuilder.appendVariantImpl` might lead to `StackOverflow` [flink] via GitHub
• 2026/10/30 [jira] [Updated] (FLINK-31245) Adaptive scheduler does not reset the state of GlobalAggregateManager when rescaling Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-30112) Improve docs re state compression Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-27849) Harden correctness for non-deterministic updates present in the changelog pipeline Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-41273) Allow UNION, INTERSECT and EXCEPT on unbounded tables in the Table API ASF GitHub Bot (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-30970) Fix SQL Client doc still uses old style output Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-36290) OutOfMemoryError in connect test run Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-29172) Add built-in string_split function. Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-30524) Support full screen viewing on the Logs/Stdout/Thread Dump page Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-28985) support create table like view Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-28909) Add ribbon filter policy option in RocksDBConfiguredOptions Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-29150) TIMESTAMPDIFF microsecond unit for table api Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-29858) Jdbc reading supports setting multiple queryTemplates Yuepeng Pan (Jira)
• 2026/10/30 Re: [PR] [FLINK-41256][runtime] Fail on operators changing the current key out of order in BATCH execution [flink] via GitHub
• 2026/10/30 Re: [PR] [hotfix][ci] Run python doc checks in parallel [flink] via GitHub
• 2026/10/30 Re: [PR] [FLINK-41267] Skip state size in cluster info when checkpointing is disabled [flink-kubernetes-operator] via GitHub
• 2026/10/30 [jira] [Updated] (FLINK-41157) Stateless jobs with HA enabled cannot be recovered or restarted when HA metadata is missing Dennis-Mircea Ciupitu (Jira) via issues
• 2026/10/30 [jira] [Updated] (FLINK-34559) TVF Window Aggregations might get stuck Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-41157) Stateless jobs with HA enabled cannot be recovered or restarted when HA metadata is missing Dennis-Mircea Ciupitu (Jira) via issues
• 2026/10/30 [jira] [Updated] (FLINK-21783) Allow HeapBackend snapshotting customization Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-40842) Streaming semi/anti join over-counts matches for right-side updates without UPDATE_BEFORE Sergey Nuyanzin (Jira) via issues
• 2026/10/30 [jira] [Updated] (FLINK-23412) Improve sourceSink description Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-35311) FLIP-454: New Apicurio Avro format Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-23379) interval left join null value result out of order Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-21940) Rowtime/proctime should be obtained from getTimestamp instead of getLong Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-23350) Write doc for change log disorder by special operators Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-22897) FlinkSQL1.12 Sink to Hive with diffrent parallelism will due to produce many small files Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Commented] (FLINK-34224) ChangelogStorageMetricsTest.testAttemptsPerUpload(ChangelogStorageMetricsTest timed out Martijn Visser (Jira) via issues
• 2026/10/30 [jira] [Updated] (FLINK-21765) Remove implementation-specific MetricGroup parents Yuepeng Pan (Jira)
• 2026/10/30 Re: [PR] [Backport][FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join (release-2.4) [flink] snuyanzin (via GitHub) via issues
• 2026/10/30 [jira] [Updated] (FLINK-23660) Hive Catalog support truncate table Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-26144) SavepointFormatITCase did NOT fail with changelog.enabled randomized Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-19562) the /flink/docs/docker/run.sh cause an error with numeric username Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-39985) Drop ReplaceMinusWithAntiJoinRule Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-34608) Migrate BatchPhysicalValuesRule Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-25887) FLIP-193: Snapshots ownership follow ups Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Commented] (FLINK-41269) Exception thrown from an operator's `close()` during failure cleanup is TaskManager-fatal since FLINK-38180 (it was suppressed before) Piotr Nowojski (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-41039) A projection on top of EXCEPT ALL or INTERSECT ALL is pushed into both inputs and changes the result Martijn Visser (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-36881) Introduce GroupTableAggFunction in GroupTableAggregate with Async State API Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-22065) Improve the error message when input invalid command in the sql client Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-18592) StreamingFileSink fails due to truncating HDFS file failure Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-23815) Separate the concerns of PendingCheckpoint and CheckpointPlan Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-41277) test_file_sink.sh hangs in the second OpenSSL linkage run ASF GitHub Bot (Jira)
• 2026/10/30 Re: [PR] [FLINK-41277][tests] `test_file_sink.sh` hangs in the second OpenSSL linkage run [flink] via GitHub
• 2026/10/30 [jira] [Updated] (FLINK-28777) Add configure session API for sql gateway rest endpoint Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-28838) Avoid to notify the elementQueue consumer when the fetch result is empty Yuepeng Pan (Jira)
• 2026/10/30 Re: [PR] [hotfix][ci] Use native git in ci [flink] snuyanzin (via GitHub) via issues
• 2026/10/30 [jira] [Updated] (FLINK-29343) Fix fail to execute ddl in HiveDialect when use specifc catalog in sql statement Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-34264) Prometheuspushgateway's hosturl can use basicAuth certification login Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-29150) TIMESTAMPDIFF microsecond unit for table api Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-21375) Refactor HybridMemorySegment Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-21053) Prevent potential RejectedExecutionExceptions in CheckpointCoordinator failing JM Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-28097) Remove bundling of formats-common in json/csv format Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-40737) COLLECT over a non-time OVER window returns only the current row instead of the running window Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-36354) Enable FORSTDB_BACKEND in async releated tests Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-28097) Remove bundling of formats-common in json/csv format Yuepeng Pan (Jira)
• 2026/10/30 [PR] [FLINK-41275][e2e] Start containers in e2e per class rather than per test in SQL e2e [flink] via GitHub
• 2026/10/30 [jira] [Updated] (FLINK-35061) Migrate TemporalJoinUtil Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-32437) Determine and set correct maxParallelism for operator chains Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-34607) Migrate BatchPhysicalUnionRule Yuepeng Pan (Jira)
• 2026/10/30 Re: [PR] [FLINK-34224][state] Fix mailbox handling in changelog storage metrics tests [flink] MartijnVisser (via GitHub) via issues
• 2026/10/30 [jira] [Updated] (FLINK-34982) FLIP-428: Fault Tolerance/Rescale Integration for Disaggregated State Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-27079) Setup cron jobs Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-30821) The optimized exec plan generated by OverAggregateTest#testDiffPartitionKeysWithDiffOrderKeys2 in the case of all-blocking is not as expected Yuepeng Pan (Jira)

• Earlier messages
• Later messages