issues  

Messages by Date

• 2026/05/05 [jira] [Updated] (FLINK-32444) Enable object reuse for Flink SQL jobs by default Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-32745) Add a flag to skip InputSelectable preValidate step Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-32738) PROTOBUF format supports projection push down Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-32682) Introduce option for choosing time function evaluation methods Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-32603) Avoid consuming twice when two pipelines have the same table source Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-32535) CheckpointingStatisticsHandler periodically returns NullArgumentException after job restarts Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-32577) Avoid memory fragmentation when running CI for flink-table-planner module Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-32699) select typeof(proctime()); throw exception in sql-client Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-32607) Kafka table source and json format support projection pushdown Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-32641) json format supports pojo type Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-32488) Introduce configuration to control ExecutionGraph cache in REST API Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-33528) Externalize Python connector code Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-32530) array_position semantic should align with array_contains instead of spark Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-33498) Do not allow manually triggering incremental checkpoints with full checkpoint configured Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-33162) seperate the executor in DefaultDispatcherResourceManagerComponentFactory for MetricFetcher and webMonitorEndpoint Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-33202) FLIP-327: Support switching from batch to stream mode to improve throughput when processing backlog data Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-32742) Remove flink-examples-batch module Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-33120) FLIP-361: Improve GC Metrics Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-33085) Improve the error message when the invalidate lookupTableSource without primary key is used as temporal join table Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-32873) Add configuration to allow disabling SQL query hints Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-32871) Support BuiltInMethod TO_TIMESTAMP with timezone options Yuepeng Pan (Jira)
• 2026/05/05 [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/05/05 [jira] [Updated] (FLINK-31654) DataStreamUtils.reinterpretAsKeyedStream() should not override the user specified chaining strategy. Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-32537) Add compatibility annotation for REST API classes Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-32753) Print JVM flags on AZP Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-32573) Translate "Custom Serialization for Managed State" page into Chinese Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-32427) FLIP-295: Support lazy initialization of catalogs and persistence of catalog configurations Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-32264) Add FIELD support in SQL & Table API Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-31666) Add ARRAY_OVERLAP supported in SQL & Table API Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-32263) Add ELT support in SQL & Table API Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-31841) Redundant local variables in AllWindowedStream#reduce Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-31691) Add MAP_FROM_ENTRIES supported in SQL & Table API Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-30467) Improve the accuracy of estimating the row count of LocalHashAgg to make more two-phase HashAgg operators effective Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-31336) interval type process has problem in table api and sql Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-31617) Upgrade the SnakeYaml Maven dependency Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-31267) Fine-Grained Resource Management supports table and sql levels Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-32184) Use revision version property Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-31729) Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-31682) map_from_arrays should take whether allow duplicate keys and null key into consideration Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-31706) The default source parallelism should be the same as execution's default parallelism under adaptive batch scheduler Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-31245) Adaptive scheduler does not reset the state of GlobalAggregateManager when rescaling Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-31249) Checkpoint timeout mechanism fails when finalizeCheckpoint is stuck Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-31161) upgrade MojoHaus Versions Maven Plugin to 2.14.2 Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-30970) Fix SQL Client doc still uses old style output Yuepeng Pan (Jira)
• 2026/05/05 [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/05/05 [jira] [Updated] (FLINK-30738) Disable verbose mode Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-31193) The option `table.exec.hive.native-agg-function.enabled` should work at job level when using it in SqlClient side Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-31006) job is not finished when using pipeline mode to run bounded source like kafka/pulsar Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-31116) Support taskmanager related parameters in session mode Support job granularity setting Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-30524) Support full screen viewing on the Logs/Stdout/Thread Dump page Yuepeng Pan (Jira)
• 2026/05/05 Re: [PR] [hotfix][docs] Correct registerOnTime reference in PTF documentation [flink] via GitHub
• 2026/05/05 [jira] [Updated] (FLINK-29172) Add built-in string_split function. Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-29646) SQL Gateway should return a simpler error message Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-29551) Improving adaptive hash join by using sort merge join strategy per partition instead of all partitions Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-30380) Look into enabling parallel compilation on CI Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-29559) Disable Join Reorder and Hash join for these tables whose statistics are unavailable in batch mode Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-30399) Enable connectors to use config docs generator Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-30379) Decouple connector docs integration from connector releases Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-30285) Inline checkstyle config into pom Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-29656) Modify all join-related sql tests to make having statistics as the default choice Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-30050) [Umbrella] Externalize Flink connectors Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-29967) Optimize determinism requirements from sink node with considering that SinkUpsertMaterializer already supports upsertKey Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-30292) Better support for conversion between DataType and TypeInformation Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-30290) IteratorSourceReaderBase should report END_OF_INPUT sooner Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-29724) Supports hive last_value function by native implementation Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-30289) RateLimitedSourceReader uses wrong signal for checkpoint rate-limiting Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-29699) Json format parsing supports converting strings at the end with Z and numbers to timestamp Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-29723) Supports hive first_value function by native implementation Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-30112) Improve docs re state compression Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-30246) Registering the same metric object with different name and group will conflict in metric reporter Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-30087) sql-gateway-api is bundled twice in the distribution Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-29941) Support SQL Client connects to SQL Gateway Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-30284) Make datadog reporter url configurable Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-29912) jdbc scan.partition.column can specify any type of field Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-29858) Jdbc reading supports setting multiple queryTemplates Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-29776) [JUnit5 Migration] Module: flink-statebackend-changelog Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-29547) Select a[1] which is array type for parquet complex type throw ClassCastException Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-29530) CommittableMessageTypeInfo#toString may force client to have S3 credentials Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-29459) Sink v2 has bugs in supporting legacy v1 implementations with global committer Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-29368) Modify DESCRIBE statement docs for new syntax Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-29330) Provide better logs of MiniCluster shutdown procedure Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-29775) [JUnit5 Migration] Module: flink-statebackend-rocksdb Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-29192) Add completeness test for built-in functions between Java and Python Table API Yuepeng Pan (Jira)
• 2026/05/05 [PR] [hotfix][docs] Correct registerOnTime reference in PTF documentation [flink] via GitHub
• 2026/05/05 [jira] [Updated] (FLINK-29717) Supports hive udaf such as sum/count by native implementation Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-29150) TIMESTAMPDIFF microsecond unit for table api Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-29355) Sql parse failed because of Desc catalog.database.table is incorrectly parsed to desc catalog Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-29343) Fix fail to execute ddl in HiveDialect when use specifc catalog in sql statement Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-29339) JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager blocks main thread Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-29240) Unify the ClassLoader in StreamExecutionEnvironment and TableEnvironment Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-29021) [Umbrella] Add docs for Hive Compatibility Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-29027) Fix HiveTableSink failed to report statistic to hive metastore in stream mode Yuepeng Pan (Jira)
• 2026/05/05 [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/05/05 [jira] [Updated] (FLINK-29058) Analyze table xxx For columns will thrown error while encounter String type column with null value Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-28893) Add conv function supported in SQL & Table API Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-29060) can not set rewriteBatchedStatements parameter for JDBC catalog for MySQL Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-29003) sqlServerDialect should support limit clause Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-28929) Add built-in datediff function. Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-28919) Add built-in generate_series function. Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-28901) CassandraSinkBaseTest.testTimeoutExceptionOnInvoke failed with TestTimedOutException Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-29001) Migrate datadog reporter to v2 metric submission API Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-28830) new stack udtf doesn't support atomic type Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-28838) Avoid to notify the elementQueue consumer when the fetch result is empty Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-28909) Add ribbon filter policy option in RocksDBConfiguredOptions Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-28732) Deprecate ambiguous StateTTLConfig#cleanFullSnapshot API Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-28777) Add configure session API for sql gateway rest endpoint Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-28726) CompileException: BoundedOverAggregateHelper must implement method AggsHandeFunction.setWindowSize(int) Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-28538) Eagerly emit a watermark the first time we exceed Long.MIN_VALUE Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-28813) new stach builtinfunction validateClassForRuntime it not correct Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-28583) make flink dist log4j dependency simple and clear Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-28737) FlinkRelMdUpsertKeys should consider the case when the condition of a calc node is non-deterministic Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-28764) Support more than 64 distinct aggregate function calls in one aggregate SQL query Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-28097) Remove bundling of formats-common in json/csv format Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-28104) Drop the unused order parameter in FirstValueFunction/LastValueFunction Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-28399) Refactor CheckedThread to accept runnable via constructor Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-28516) UI is misleading when source doesn't emit watermark due to misconfigured idleness Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-28398) CheckpointCoordinatorTriggeringTest.discardingTriggeringCheckpointWillExecuteNextCheckpointRequest( gets stuck Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-28109) Delete useful code in the row emitter. Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-28074) show statistics details for DESCRIBE EXTENDED Yuepeng Pan (Jira)
• 2026/05/05 [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/05/05 [jira] [Updated] (FLINK-28061) create new tech blog for connector development based on Source API Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-28022) Support Google Cloud PubSub connector in Python DataStream API Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-27074) python_job.py should write to TEST_DATA_DIR Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-27954) JobVertexFlameGraphHandler does not work on standby Dispatcher Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-27849) Harden correctness for non-deterministic updates present in the changelog pipeline Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-28401) Remove snapshot repo from quickstarts for released versions Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-28422) Fall back to lastest supported HiveShim when user use a higher hive version Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-27591) Improve the plan for batch queries when statistics is unavailable Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-28428) Example in the Elasticsearch doc of fault tolerance section is missing Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-27492) Flink table scala example does not including the scala-api jars Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-28042) Create an extension for resetting HiveConf Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-27632) Improve connector testing framework to support more cases Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-27364) Support DESC EXTENDED partition statement for partitioned table Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-27401) CEP supports AggregateFunction in IterativeCondition Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-27593) Parquet/Orc format reader optimization Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-27809) Clarify that cluster-id is mandatory for Kubernetes HA in standalone mode Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-27583) Improve the plan for TPC-DS queries Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-27858) Hive source support filter push down for parquet format Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-27455) [JUnit5 Migration] SnapshotMigrationTestBase Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-27596) [Umbrella] Optimize Hive source Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-27237) Partitioned table statement enhancement Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-26831) Move JarHandlers to flink-runtime Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-27191) Support multi kerberos-enabled Hive clusters Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-27079) Setup cron jobs Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-27077) Setup per-commit builds Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-27268) build sql query error in JdbcDynamicTableSource Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-26764) Support RESPECT NULLS for FIRST_VALUE/LAST_VALUE Yuepeng Pan (Jira)
• 2026/05/05 [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/05/05 [jira] [Updated] (FLINK-26692) migrate TpcdsTestProgram.java to new source Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-27080) Enable builds for pull requests Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-26942) Support SELECT clause in CREATE TABLE(CTAS) Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-26761) Fix the cast exception thrown by PreValidateReWriter when insert into/overwrite a partitioned table. Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-26927) Improve FlinkContainers to better support JM restarting Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-26732) DefaultResourceAllocationStrategy need more log info to troubleshoot Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-26559) Support Customized Kubernetes Schedulers for Flink Kubernetes Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-26253) Speed up detection of dropped message in MessageSerializationTest Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-25862) Refactor SharedStateRegistry to not limit StreamStateHandle to register/unregister Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-25419) Support the metadata column to generate dynamic index Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-25512) Materialization Files are not cleaned up if no checkpoint is using it Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-25725) Agile configurable modules in web ui Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-25900) Create view example does not assign alias to functions resulting in generated names like EXPR$5 Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-26664) Improve Python exception messages to be more Pythonic in PyFlink Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-26477) Finalize the window support in Python DataStream API Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-26129) Using fail method instead of kill method when yarn application deployment error occures Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-26144) SavepointFormatITCase did NOT fail with changelog.enabled randomized Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-26003) Use Jackson serialization for persisting TaskExecutor state to working directory Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-25444) ClosureCleaner rejects ExecutionConfig as not be Serializable due to TextElement Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-25354) Document API graduation process Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-25612) Update the outdated illustration of ExecutionState in the documentation Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-25887) FLIP-193: Snapshots ownership follow ups Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-25350) Verify stability guarantees of annotated classes Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-25349) Add test that ensures that parameter/return types have the same or stronger stability guarantee than method Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-25325) Migration Flink from Junit4 to Junit5 Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-25353) Add tests to ensure API graduation process is honoured Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-25346) FLIP-197: API stability graduation process Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-25352) Update stability annotations to include the since and missedGraduations fields Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-25290) Add table source and sink test suite in connector testing framework Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-25345) FLIP-196: Source API stability guarantees Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-24900) Support to run multiple shuffle plugins in one session cluster Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-25027) Allow GC of a finished job's JobMaster before the slot timeout is reached Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-25322) Support no-claim mode in changelog state backend Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-25244) Deprecate Java 8 support Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-25291) Add failure cases in DataStream source and sink suite of connector testing framework Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-25283) End-to-end application modules create oversized jars Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-25043) Allow calls to public @VisibleForTesting from the same package Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-24951) Allow watch bookmarks to mitigate frequent watcher rebuilding Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-24901) Some further improvements of the pluggable shuffle framework Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-24849) Only return stacktrace if RestHandlerException has a cause Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-24757) Yarn application is not terminated after the job finishes when submitting a yarn-per-job insert job with SQL client Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-24683) Add Support for Azure Synapse Analytics Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-24547) A function named row_kind() can get row_kind Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-24666) Add job level "table.exec.state-stale.error-handling" option and apply to related stateful stream operators Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-24688) yarn.application-attempt-failures-validity-interval link url is invalid Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-24636) Move cluster deletion operation cache into ResourceManager Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-24386) JobMaster should guard against exceptions from OperatorCoordinator Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-24517) Streamline Flink releases Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-24680) Expose UserCodeClassLoader in OperatorCoordinator.Context for registering release hooks Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-24536) flink sql where condition is not supported != writing Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-24376) Operator name in OperatorCoordinator should not use chained name Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Commented] (FLINK-24376) Operator name in OperatorCoordinator should not use chained name Yuepeng Pan (Jira)

• Earlier messages