issues  

Messages by Date

• 2026/10/30 [jira] [Updated] (FLINK-32699) select typeof(proctime()); throw exception in sql-client Yuepeng Pan (Jira) via issues
• 2026/10/30 [jira] [Updated] (FLINK-32738) PROTOBUF format supports projection push down Yuepeng Pan (Jira) via issues
• 2026/10/30 [jira] [Updated] (FLINK-32682) Introduce option for choosing time function evaluation methods Yuepeng Pan (Jira) via issues
• 2026/10/30 [jira] [Updated] (FLINK-32641) json format supports pojo type Yuepeng Pan (Jira) via issues
• 2026/10/30 [jira] [Updated] (FLINK-34397) Resource wait timeout can't be disabled Yuepeng Pan (Jira) via issues
• 2026/10/30 [jira] [Updated] (FLINK-32607) Kafka table source and json format support projection pushdown Yuepeng Pan (Jira) via issues
• 2026/10/30 [jira] [Updated] (FLINK-36186) Speed up RocksDB close during manual compaction Yuepeng Pan (Jira) via issues
• 2026/10/30 Re: [PR] [FLINK-38990][Runtime/Checkpointing] Support configurable initial delay for first checkpoint trigger [flink] github-actions[bot] (via GitHub) via issues
• 2026/10/30 Re: [PR] [FLINK-39968] [core] Reduce redundant AtomicBoolean allocation in MemorySegment to improve construction performance [flink] github-actions[bot] (via GitHub) via issues
• 2026/10/30 Re: [PR] [FLINK-39968] [core] Reduce redundant AtomicBoolean allocation in MemorySegment to improve construction performance [flink] github-actions[bot] (via GitHub) via issues
• 2026/10/30 Re: [PR] [FLINK-39995][json] Add ISO-8601 timestamp format with explicit timezone offset support [flink] github-actions[bot] (via GitHub) via issues
• 2026/10/30 Re: [PR] [FLINK-39995][json] Add ISO-8601 timestamp format with explicit timezone offset support [flink] github-actions[bot] (via GitHub) via issues
• 2026/10/30 Re: [PR] [FLINK-38990][Runtime/Checkpointing] Support configurable initial delay for first checkpoint trigger [flink] github-actions[bot] (via GitHub) via issues
• 2026/10/30 Re: [PR] [BP-1.20][FLINK-41117][ci] Bump ubuntu to 26 in Azure and GHA [flink] spuru9 (via GitHub) via issues
• 2026/10/30 Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] Samrat002 (via GitHub) via issues
• 2026/10/30 Re: [PR] [hotfix][runtime] Fix typo 'refering' in process spec javadoc [flink] garvitlnmiit (via GitHub) via issues
• 2026/10/30 Re: [PR] Backport flink 34224 2.3 [flink] flinkbot (via GitHub) via issues
• 2026/10/30 [PR] Backport flink 34224 2.3 [flink] rakeshkodathala (via GitHub) via issues
• 2026/10/30 [jira] [Updated] (FLINK-26944) Add ADD_MONTHS supported in SQL and Table API Yuepeng Pan (Jira)
• 2026/10/30 Re: [PR] [FLINK-41263][table-planner] Add CompiledPlan support for BatchExecAdaptiveJoin [flink] jnh5y (via GitHub) via issues
• 2026/10/30 [jira] [Updated] (FLINK-34473) Migrate FlinkPruneEmptyRules Yuepeng Pan (Jira)
• 2026/10/30 Re: [PR] [FLINK-39383][Docs] Improve scan.incremental.snapshot.chunk.key-column documentation for MySQL/PostgreSQL/Oracle/DB2/SQLServer connectors [flink-cdc] github-actions[bot] (via GitHub) via issues
• 2026/10/30 Re: [PR] [FLINK-39950][sqlserver] Fix chunk key column search restricted to primary key columns [flink-cdc] github-actions[bot] (via GitHub) via issues
• 2026/10/30 Re: [PR] [FLINK-40038][pipeline-connector/mysql] Cache inferred row DataType in MySQL deserialization [flink-cdc] github-actions[bot] (via GitHub) via issues
• 2026/10/30 [jira] [Updated] (FLINK-29559) Disable Join Reorder and Hash join for these tables whose statistics are unavailable in batch mode 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 [PR] [FLINK-41273][table] Support set operations on unbounded tables in the Table API [flink] via GitHub
• 2026/10/30 [jira] [Updated] (FLINK-26129) Using fail method instead of kill method when yarn application deployment error occures Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-26927) Improve FlinkContainers to better support JM restarting Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-34670) The asyncOperationsThreadPool in SubtaskCheckpointCoordinatorImpl can only create one worker thread Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-41279) Support the :: infix cast operator Ramin Gharib (Jira)
• 2026/10/30 [jira] [Commented] (FLINK-40485) FLIP 604: Complete VARIANT primitive coverage with UUID and timestamps Sumin Joo (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-29724) Supports hive last_value function by native implementation Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Assigned] (FLINK-41280) CAST of a TIMESTAMP before 1970 to DATE or TIME returns a wrong value Ramin Gharib (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-14383) Support python UDFs with constant value of time interval types 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-24094) Support DROP PARTITION by partial partition specification 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-23849) Support react to the node decommissioning change state on yarn and do graceful restart Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-33319) Add AverageTime metric to measure delta change in GC time Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-23147) ThreadPools can be poisoned by context class loaders Yuepeng Pan (Jira)
• 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-23000) Allow downloading all Flink logs from the UI Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-23589) Support Avro Microsecond precision Yuepeng Pan (Jira)
• 2026/10/30 Re: [PR] [BP-2.4][FLINK-41247][queryable-state] Close server channels before shutting down the Netty event loops [flink] via GitHub
• 2026/10/30 [jira] [Updated] (FLINK-27583) Improve the plan for TPC-DS queries Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-34975) FLIP-427: ForSt - Disaggregated State Store Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-24122) Add support to do clean in history server Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Commented] (FLINK-41276) Make License check CI parallel Sergey Nuyanzin (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-26967) Fix race condition in CopyOnWriteStateMap 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-34445) Integrate new endpoint with Flink UI metrics section Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-24536) flink sql where condition is not supported != writing 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-24517) Streamline Flink releases Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-38459) SinkUpsertMaterializer V2 (FLIP-544) Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-28538) Eagerly emit a watermark the first time we exceed Long.MIN_VALUE Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-29723) Supports hive first_value function by native implementation Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-29330) Provide better logs of MiniCluster shutdown procedure Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-21125) Sum or Sum0 overflow quietly Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-14340) Specify an unique DFSClient name for Hadoop FileSystem Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-24386) JobMaster should guard against exceptions from OperatorCoordinator Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-24201) HistoryServer didn't contain TaskManager Logs Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-25353) Add tests to ensure API graduation process is honoured Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-24343) Revisit Scheduler and Coordinator Startup Procedure Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-36911) add more calcite rules to improve flink performance because calcite has upgrade 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 [jira] [Created] (FLINK-41275) Start containers in e2e per class rather than per test in SQL e2e Sergey Nuyanzin (Jira)
• 2026/10/30 Re: [PR] [hotfix][python] Fix Java 8 compilation of PythonTypeUtils [flink] via GitHub
• 2026/10/30 [jira] [Updated] (FLINK-25612) Update the outdated illustration of ExecutionState in the documentation Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-25512) Materialization Files are not cleaned up if no checkpoint is using it Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-25354) Document API graduation process 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-27077) Setup per-commit builds Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-37593) Add Some Reduce Expression Rules Yuepeng Pan (Jira)
• 2026/10/30 Re: [PR] [BP-2.4][FLINK-41117][ci] Bump ubuntu to 26 in Azure and GHA [flink] via GitHub
• 2026/10/30 [jira] [Updated] (FLINK-35206) Desc table syntax support materialized table Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-5346) Remove all ad-hoc config loading via GlobalConfiguration Yuepeng Pan (Jira)
• 2026/10/30 Re: [PR] [FLINK-41263][table-planner] Add CompiledPlan support for BatchExecAdaptiveJoin [flink] flinkbot (via GitHub) via issues
• 2026/10/30 [jira] [Updated] (FLINK-41263) Add CompiledPlan annotations to BatchExecAdaptiveJoin ASF GitHub Bot (Jira) via issues
• 2026/10/30 Re: [PR] [hotfix][runtime] Fix typo in JobManagerProcessSpec and TaskExecutorP… [flink] via GitHub
• 2026/10/30 [jira] [Updated] (FLINK-23815) Separate the concerns of PendingCheckpoint and CheckpointPlan 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-20834) Add metrics for reporting the memory usage and CPU usage of the Python UDF workers Yuepeng Pan (Jira)
• 2026/10/30 [PR] [FLINK-41263][table-planner] Add CompiledPlan support for BatchExecAdaptiveJoin [flink] bvarghese1 (via GitHub) via issues
• 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-41117) Move CI to ubuntu 26 Sergey Nuyanzin (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-41281) Allow CAST from a VARIANT timestamp to the other temporal types Ramin Gharib (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-17274) Maven: Premature end of Content-Length delimited message body Yuepeng Pan (Jira)
• 2026/10/30 [PR] [FLINK-41157] Stateless jobs with HA enabled cannot be recovered or restarted when HA metadata is missing [flink-kubernetes-operator] Dennis-Mircea (via GitHub) via issues
• 2026/10/30 [jira] [Updated] (FLINK-41157) Stateless jobs with HA enabled cannot be recovered or restarted when HA metadata is missing ASF GitHub Bot (Jira) via issues
• 2026/10/30 Re: [D] [Discussion] Context compaction for Flink Agents [flink-agents] via GitHub
• 2026/10/30 Re: [PR] [FLINK-36725] Add CompiledPlan suppport for BatchExecRuntimeFilter [flink] via GitHub
• 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-30738) Disable verbose mode Yuepeng Pan (Jira)
• 2026/10/30 [PR] [hotfix][ci] Use more threads for download during ci, also download dep POMs in parallel [flink] via GitHub
• 2026/10/30 [jira] [Updated] (FLINK-18563) Add Support for Azure Cosmos DB DataStream Connector 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-29021) [Umbrella] Add docs for Hive Compatibility Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-29866) Split flink-dist 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-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-36132) Remove codes that references TableSource and TableSink directly at the API level. Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-36134) Remove the classes associated with TableSource and TableSink as part of the optimization process. Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-35534) Support profiler for benchmarks Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-35163) Utilize ForSt's native MultiGet API to optimize remote state access Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Assigned] (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-16323) Support to join a static table in streaming mode Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-40557) Make operation column optional in TO_CHANGELOG output Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-34610) Migrate StreamPhysicalLimitRule Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-35327) SQL Explain show push down condition 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-34612) Migrate StreamPhysicalValuesRule Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-38351) Docker images support OpenJDK 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-34982) FLIP-428: Fault Tolerance/Rescale Integration for Disaggregated State Yuepeng Pan (Jira)
• 2026/10/30 [jira] [Updated] (FLINK-32184) Use revision version property 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-35480) Add FIELD function in SQL & Table API Yuepeng Pan (Jira)
• 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)

• Earlier messages
• Later messages