issues  

Messages by Date

• 2026/10/30 [jira] [Updated] (FLINK-20110) Support 'merge' method for first_value and last_value UDAF Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-23445) Separate data and timer connection into different channels for Python Table API operators Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-22237) Flamegraph component calls draw method from template Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-22594) Report oom killed pod in k8s resource manager Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-22975) Specify port or range for k8s service Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-23141) Support KafkaSerializationSchema in Kafka connector for Python DataStream API Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-23000) Allow downloading all Flink logs from the UI Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-21649) Allow extension of CopyOnWrite state classes 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-23141) Support KafkaSerializationSchema in Kafka connector for Python DataStream API Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-21876) Handle it properly when the returned value of Python UDF doesn't match the defined result type Yuepeng Pan (Jira)
• 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-22605) Python UDF should only be created once regardless of how many times it is invoked Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-23555) Improve common subexpression elimination by using local references Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-22371) Chinese grammatical error Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-23564) Make taskmanager.out and taskmanager.err rollable Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-22975) Specify port or range for k8s service Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-22223) Explicitly configure rest.address in distribution config Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-23752) Add document for using HiveSource API Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-23403) Decrease default values for heartbeat timeout and interval Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-22371) Chinese grammatical error 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] [Updated] (FLINK-22605) Python UDF should only be created once regardless of how many times it is invoked Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-21783) Allow HeapBackend snapshotting customization Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-22334) Fail to translate the hive-sql in STREAMING mode Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-21649) Allow extension of CopyOnWrite state classes Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-22594) Report oom killed pod in k8s resource manager Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-23860) Conversion to relational algebra failed to preserve datatypes Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-22909) Supports change log inputs for event time operators Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-22585) Add deprecated message when "-m yarn-cluster" is used Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-21799) Detect and fail explicitly on managed memory leaking Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-23623) Over expression should allow to order by any fields in batch mode Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-23660) Hive Catalog support truncate table Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-21784) Allow HeapBackend RestoreOperation customization Yuepeng Pan (Jira)
• 2026/10/30 Re: [PR] [BP-2.2][FLINK-40499][runtime] Emit ACTIVE before final MAX_WATERMARK at drain [flink] via GitHub
• 2026/10/30 [jira] [Updated] (FLINK-21126) Reconsider FLINK_PROPERTIES Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-21408) Clarify which DataStream sources support Batch execution Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-20787) Improve the Table API to solve user friction Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-19895) Unify Life Cycle Management of ResultPartitionType Pipelined Family Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-21613) Parse Compute Column with `IN` expression throws NPE Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-20155) java.lang.OutOfMemoryError: Direct buffer memory Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-19881) Optimize temporal join with upsert-Source(upsert-kafka) Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-20246) Add documentation on Python worker memory tuning in the memory tuning page Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-20305) Iterative job with maxWaitTimeMillis does not terminate Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-21022) flink-connector-es add onSuccess handler after bulk process for sync success data to other third party system for data consistency checking Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-20518) WebUI should escape characters in metric names Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-21578) Closeable Sink Committer/GlobalCommitter were created to function in onestep during job graph composition Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-19722) Pushdown Watermark to SourceProvider (new Source) Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Resolved] (FLINK-40002) `PushFilterInCalcIntoTableSourceScanRule` misroutes metadata predicates, crashing compiled-plan restore Sergey Nuyanzin (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-20154) Improve error messages when using CLI with wrong target Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-19527) Update SQL Pages Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-20572) HiveCatalog should be a standalone module Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-20788) It doesn't support to use cube/rollup/grouping sets in the Table API Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-16774) expose HBaseUpsertSinkFunction hTableName and schema for other system Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-19819) SourceReaderBase supports limit push down Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-20190) A New Window Trigger that can trigger window operation both by event time interval、event count for DataStream API Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-18564) Add Support for Azure Event Hub DataStream Connector Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-21409) Add Avro to DataTypes & Serialization docs Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-18627) Get unmatch filter method records to side output Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-16137) Translate all DataStream API related pages into Chinese Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-19038) It doesn't support to call Table.limit() continuously Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-19499) Expose Metric Groups to Split Assigners Yuepeng Pan (Jira)
• 2026/10/30 Re: [PR] [BP-2.2][FLINK-40499][runtime] Emit ACTIVE before final MAX_WATERMARK at drain [flink] via GitHub
• 2026/10/30 [jira] [Updated] (FLINK-18022) Add e2e test for new streaming file sink Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-18565) Add Support for Azure Event Grid DataStream Connector Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-19362) Remove confusing comment for `DOT` operator codegen Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-15740) Remove Deadline#timeLeft() Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-17405) add test cases for cancel job in SQL client Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-17362) Improve table examples to reflect latest status Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-17785) Refactor orc shim to create a OrcShimFactory in hive Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-15645) enable COPY TO/FROM in Postgres JDBC source/sink for faster batch processing Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-16323) Support to join a static table in streaming mode Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-16073) Translate "State & Fault Tolerance" pages into Chinese Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-16799) add hive partition limit when read from hive Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-16762) Relocation Beam dependency of PyFlink Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-17642) Exception while reading broken ORC file is hidden Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-16466) Group by on event time should produce insert only result Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-16077) Translate "Custom State Serialization" page into Chinese Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-15859) Unify identifiers in the interface methods of CatalogManager Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-16609) Promotes the column name representation of SQL-CLI 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-17784) Better detection for parquet and orc in hive Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-15860) Store temporary functions as CatalogFunctions in FunctionCatalog Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-18201) Support create_function in Python Table API Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-18624) Document CREATE TEMPORARY TABLE Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-16701) Elasticsearch sink support alias for indices. Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-15553) Create table ddl support comment after computed column Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-18578) Add rejecting checkpoint logic in source Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-18986) KubernetesSessionCli creates RestClusterClient for detached deployments Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-18567) Add Support for Azure Cognitive Search Table & SQL Connector Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-19263) Enforce alphabetical order in configuration option docs Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-16952) Parquet file system format support filter pushdown Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-20457) Fix the handling of timestamp in DataStream.from_collection Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-16466) Group by on event time should produce insert only result Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-20305) Iterative job with maxWaitTimeMillis does not terminate Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-16774) expose HBaseUpsertSinkFunction hTableName and schema for other system Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-19881) Optimize temporal join with upsert-Source(upsert-kafka) Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-18564) Add Support for Azure Event Hub DataStream Connector Yuepeng Pan (Jira)
• 2026/10/30 [I] [Bug][API] Return ChatResponseEvent from ctx.chat() to preserve failure status and structured output [flink-agents] via GitHub
• 2026/10/30 Re: [PR] [FLINK-41282][table-planner] Use each multi-join step's own join colu… [flink] via GitHub
• 2026/10/30 [jira] [Updated] (FLINK-16143) Turn on more date time functions of blink planner Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-17405) add test cases for cancel job in SQL client Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-20788) It doesn't support to use cube/rollup/grouping sets in the Table API Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-16799) add hive partition limit when read from hive Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-21613) Parse Compute Column with `IN` expression throws NPE Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-17011) Introduce builder to create AbstractStreamOperatorTestHarness for testing Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-21648) FLIP-151: Incremental snapshots for heap-based state backend Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-16701) Elasticsearch sink support alias for indices. Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-18565) Add Support for Azure Event Grid DataStream Connector Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-21375) Refactor HybridMemorySegment 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 [jira] [Updated] (FLINK-18567) Add Support for Azure Cognitive Search Table & SQL Connector Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-19846) Grammar mistakes in annotations and log Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-20155) java.lang.OutOfMemoryError: Direct buffer memory Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-20578) Cannot create empty array using ARRAY[] 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-18199) Translate "Filesystem SQL Connector" page into Chinese Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-17785) Refactor orc shim to create a OrcShimFactory in hive Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-19254) Invalid UTF-8 start byte exception Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-16776) Support schema evolution for Hive tables Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-17642) Exception while reading broken ORC file is hidden Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-20818) End to end test produce excessive amount of logs Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-19038) It doesn't support to call Table.limit() continuously Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-17274) Maven: Premature end of Content-Length delimited message body Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-17826) Add missing custom query support on new jdbc connector 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 [jira] [Updated] (FLINK-21022) flink-connector-es add onSuccess handler after bulk process for sync success data to other third party system for data consistency checking Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-20834) Add metrics for reporting the memory usage and CPU usage of the Python UDF workers Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-20190) A New Window Trigger that can trigger window operation both by event time interval、event count for DataStream API Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-19895) Unify Life Cycle Management of ResultPartitionType Pipelined Family 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-19722) Pushdown Watermark to SourceProvider (new Source) Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-20787) Improve the Table API to solve user friction Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-19527) Update SQL Pages Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-16137) Translate all DataStream API related pages into Chinese Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-21408) Clarify which DataStream sources support Batch execution Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-18627) Get unmatch filter method records to side output Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-19774) Introduce Sub Partition View Version for Approximate Local Recovery Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-15553) Create table ddl support comment after computed column Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-20484) Improve hive temporal table exception Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-21634) ALTER TABLE statement enhancement Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-21637) Wrong results when filtering by timestamp type Yuepeng Pan (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-21578) Closeable Sink Committer/GlobalCommitter were created to function in onestep during job graph composition Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-16609) Promotes the column name representation of SQL-CLI Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-18578) Add rejecting checkpoint logic in source Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-16762) Relocation Beam dependency of PyFlink Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-20687) Missing 'yarn-application' target in CLI help message Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-19425) Correct the usage of BulkWriter#flush and BulkWriter#finish Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-19935) Supports configure heap memory of sql-client to avoid OOM Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-18624) Document CREATE TEMPORARY TABLE Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-17362) Improve table examples to reflect latest status Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-20853) Add reader schema null check for AvroDeserializationSchema when recordClazz is GenericRecord Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-18022) Add e2e test for new streaming file sink Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-15740) Remove Deadline#timeLeft() Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-17784) Better detection for parquet and orc in hive Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-21125) Sum or Sum0 overflow quietly Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-21126) Reconsider FLINK_PROPERTIES Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-19482) OrcRowInputFormat does not define serialVersionUID Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-15859) Unify identifiers in the interface methods of CatalogManager 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-19263) Enforce alphabetical order in configuration option docs Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-20154) Improve error messages when using CLI with wrong target Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-19432) Whether to capture the updates which don't change any monitored columns Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-18566) Add Support for Azure Cognitive Search DataStream Connector Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-18986) KubernetesSessionCli creates RestClusterClient for detached deployments Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-15645) enable COPY TO/FROM in Postgres JDBC source/sink for faster batch processing Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-20091) Introduce avro.ignore-parse-errors for AvroRowDataDeserializationSchema Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-41033) Savepoint history cleanup disposes the savepoint referenced by status.jobStatus.upgradeSavepointPath, causing restore failures (FileNotFoundException) ASF GitHub Bot (Jira)
• 2026/10/30 [jira] [Commented] (FLINK-41282) Multi-join upsert key inference reports keys that are not unique Anton Borisov (Jira)
• 2026/10/30 [PR] [FLINK-41282][table-planner] Use each multi-join step's own join colu… [flink] via GitHub
• 2026/10/30 [jira] [Updated] (FLINK-41282) Multi-join upsert key inference reports keys that are not unique ASF GitHub Bot (Jira)
• 2026/10/30 Re: [PR] [Backport][FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join (release-2.4) [flink] via GitHub
• 2026/10/30 Re: [PR] [Backport][FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join (release-2.2) [flink] via GitHub
• 2026/10/30 Re: [PR] [Backport][FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join (release-2.3) [flink] via GitHub
• 2026/10/30 [PR] [Backport][FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join (release-2.4) [flink] via GitHub
• 2026/10/30 [jira] [Updated] (FLINK-15003) Improve hive test performance Yuepeng Pan (Jira)
• 2026/10/30 Re: [PR] [FLINK-41033][operator] Keep upgradeSavepointPath at the newest compl… [flink-kubernetes-operator] via GitHub
• 2026/10/30 [jira] [Updated] (FLINK-15532) Enable strict capacity limit for memory usage for RocksDB Yuepeng Pan (Jira)
• 2026/10/30 [PR] [Backport][FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join (release-2.3) [flink] via GitHub
• 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 Re: [PR] [FLINK-41033][operator] Keep upgradeSavepointPath at the newest compl… [flink-kubernetes-operator] via GitHub
• 2026/10/30 Re: [PR] [FLINK-38753] [table-planner] Enrich upsert keys by equi-join equivalences [flink] via GitHub
• 2026/10/30 Re: [PR] [FLINK-40991][operator] Ignore unknown fields when reading ClusterHealthInfo [flink-kubernetes-operator] via GitHub
• 2026/10/30 [jira] [Closed] (FLINK-40991) Health info stored by an operator before 1.12 fails to deserialize after upgrading, breaking reconciliation Gyula Fora (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-18981) Support column comment for Hive tables Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-12590) Replace http links in documentation Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Resolved] (FLINK-41260) ARRAY_AGG/JSON_ARRAYAGG with ORDER BY ignores the ordering Gustavo de Morais (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-15460) planner dependencies won't be necessary for JDBC connector Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-15471) HA e2e check for empty .out files does not print specific error Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-27467) Remove CliFrontendTestBase Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-27391) Support Hive bucket table Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-17589) Extend StreamingFileSink to Support Streaming Hive Connector Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-27268) build sql query error in JdbcDynamicTableSource Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-27492) Flink table scala example does not including the scala-api jars Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-27591) Improve the plan for batch queries when statistics is unavailable Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-27364) Support DESC EXTENDED partition statement for partitioned table Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-25354) Document API graduation process Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-17539) Migrate the configuration options which do not follow the xyz.max/min pattern. Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-17535) Treat min/max as part of the hierarchy of config option Yuepeng Pan (Jira)

• Earlier messages
• Later messages