issues  

Messages by Date

• 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)
• 2026/10/30 [jira] [Updated] (FLINK-35103) [Plugin] Enhancing Flink Failure Management in Kubernetes with Dynamic Termination Log Integration Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-25725) Agile configurable modules in web ui Yuepeng Pan (Jira)
• 2026/10/30 [PR] [FLINK-41045][e2e] Increase slot request timeout in Kerberized YARN Docker tests [flink] via GitHub
• 2026/10/30 [jira] [Comment Edited] (FLINK-41282) Multi-join upsert key inference reports keys that are not unique Anton Borisov (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-32451) Refactor Confluent Schema Registry E2E Tests to remove Kafka connector dependency Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-34665) Add streaming rule for union to Rand and it convert to StreamExecDeduplicate finally Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-21184) Support temporary table/function for hive connector Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-35970) Update documentation about FLINK-26050 (merging small SST files) Yuepeng Pan (Jira)
• 2026/10/30 Re: [PR] [FLINK-30284][flink-metrics] Modify configuration of DataDog http reporter url. [flink] MartijnVisser (via GitHub) via issues
• 2026/10/30 Re: [PR] [FLINK-30284][flink-metrics] Modify configuration of DataDog http reporter url. [flink] MartijnVisser (via GitHub) via issues
• 2026/10/30 [jira] [Updated] (FLINK-18563) Add Support for Azure Cosmos DB DataStream Connector Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-34604) Migrate BatchPhysicalCalcRule 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] [Created] (FLINK-41283) Last-state upgrade fails when checkpointing is disabled and max checkpoint age is set Santwana Verma (Jira)
• 2026/10/30 Re: [PR] [FLINK-41273][table] Support set operations on unbounded tables in the Table API [flink] via GitHub
• 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)
• 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 Re: [PR] [FLINK-41276][ci] Run the License task in parallel and regroup its log so the license checks still work [flink] via GitHub
• 2026/10/30 [jira] [Updated] (FLINK-34224) ChangelogStorageMetricsTest.testAttemptsPerUpload(ChangelogStorageMetricsTest timed out ASF GitHub Bot (Jira) via issues
• 2026/10/30 [jira] [Updated] (FLINK-21179) Make sure that the open/close methods of the Python DataStream Function are not implemented when using in ReducingState and AggregatingState Yuepeng Pan (Jira)
• 2026/10/30 Re: [PR] [FLINK-41280][table] Fix CAST of a TIMESTAMP before 1970 to DATE and TIME [flink] via GitHub
• 2026/10/30 [jira] [Updated] (FLINK-20572) HiveCatalog should be a standalone module Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-32239) Unify TestJvmProcess and TestProcessBuilder Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-33528) Externalize Python connector code Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-22059) add a new option is rocksdb statebackend to enable job threads setting Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-28428) Example in the Elasticsearch doc of fault tolerance section is missing Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-17683) Pojo with no-args constructor will be treated as ROW when returned by ScalarFunction， but not when it is a field of case class. Yuepeng Pan (Jira)
• 2026/10/30 [PR] [FLINK-41279][table] Support the :: infix cast operator [flink] via GitHub
• 2026/10/30 [jira] [Updated] (FLINK-35315) MemoryManagerConcurrentModReleaseTest executes more than 15 minutes Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-16776) Support schema evolution for Hive tables 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) Martijn Visser (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-16800) TypeMappingUtils#checkIfCompatible didn't deal with nested types Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-24951) Allow watch bookmarks to mitigate frequent watcher rebuilding Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-24306) group by index throw SqlValidatorException Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-22418) The currently activated tab in the same page isn't consistent Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-31729) Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-21799) Detect and fail explicitly on managed memory leaking Yuepeng Pan (Jira)
• 2026/10/30 Re: [PR] [hotfix][ci] Use native git in ci [flink] MartijnVisser (via GitHub) via issues
• 2026/10/30 [jira] [Updated] (FLINK-23031) Support to emit window result with periodic or non_periodic Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-12358) Verify whether rest documenation needs to be updated when building pull request Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-11937) Resolve small file problem in RocksDB incremental checkpoint Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-33561) Externalize Pulsar Python connector code Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-20920) Document how to connect to kerberized HMS Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-38942) Add documentation for async python scalar function Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-21634) ALTER TABLE statement enhancement Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-34650) Migrate PushProjectIntoLegacyTableSourceScanRule Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Commented] (FLINK-41267) Cluster info fails for jobs without checkpointing, logging a WARN on every reconcile Santwana Verma (Jira)
• 2026/10/30 Re: [PR] [BP-2.3][FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink] via GitHub
• 2026/10/30 [jira] [Updated] (FLINK-30380) Look into enabling parallel compilation on CI Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-32738) PROTOBUF format supports projection push down 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] [Closed] (FLINK-30032) IOException during MAX_WATERMARK emission causes message missing Martijn Visser (Jira)
• 2026/10/30 Re: [PR] [hotfix][ci] Use native git in ci [flink] via GitHub
• 2026/10/30 Re: [PR] [FLINK-40445] Autoscaler: integration test for Kafka/Pulsar source partition-metric detection [flink-kubernetes-operator] via GitHub
• 2026/10/30 Re: [PR] [FLINK-41039][table-planner] Only push projections into the inputs of UNION ALL [flink] via GitHub
• 2026/10/30 [jira] [Updated] (FLINK-12412) Allow ListTypeInfo used for java.util.List and MapTypeInfo used for java.util.Map Yuepeng Pan (Jira)
• 2026/10/30 [PR] [hotfix][ci] Use native git in ci [flink] via GitHub
• 2026/10/30 [jira] [Comment Edited] (FLINK-36725) Add CompiledPlan annotations to BatchExecRuntimeFilter exec nodes Martijn Visser (Jira)
• 2026/10/30 [jira] [Commented] (FLINK-36725) Add CompiledPlan annotations to BatchExecRuntimeFilter exec nodes Martijn Visser (Jira)
• 2026/10/30 [jira] [Resolved] (FLINK-36725) Add CompiledPlan annotations to BatchExecRuntimeFilter exec nodes Martijn Visser (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-36725) Add CompiledPlan annotations to BatchExecRuntimeFilter exec nodes Martijn Visser (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-36725) Add CompiledPlan annotations to BatchExecRuntimeFilter exec nodes Martijn Visser (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-35698) Parquet connector fails to load ROW<x decimal(5, 2)> after save Yuepeng Pan (Jira)
• 2026/10/30 Re: [PR] [FLINK-36725] Add CompiledPlan suppport for BatchExecRuntimeFilter [flink] via GitHub
• 2026/10/30 [jira] [Updated] (FLINK-14684) Add Pinterest to Chinese Powered By page Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-29368) Modify DESCRIBE statement docs for new syntax Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Resolved] (FLINK-40958) VARIANT might fail with StackOverflow Sergey Nuyanzin (Jira)
• 2026/10/30 Re: [PR] [FLINK-36725] Add CompiledPlan suppport for BatchExecRuntimeFilter [flink] via GitHub

• Earlier messages
• Later messages