issues  

Messages by Date

• 2026/05/06 Re: [PR] [FLINK-39268][table] Expand and reuse local refs in `CalcCodeGenerator` [flink] via GitHub
• 2026/05/06 Re: [PR] [hotfix] [docs] Fix broken flink-training links in hands-on section [flink] via GitHub
• 2026/05/06 Re: [PR] Add Flink 1.20.4 release [flink-web] via GitHub
• 2026/05/06 Re: [PR] Add Flink 1.20.4 release [flink-web] via GitHub
• 2026/05/06 [I] [Feature] [integration] [java] Integrate built-in Google Gemini chat model [flink-agents] via GitHub
• 2026/05/06 [jira] [Commented] (FLINK-25672) FileSource enumerator remembers paths of all already processed files which can result in large state David Radley (Jira)
• 2026/05/06 [jira] [Updated] (FLINK-39613) Flink cdc pipeline primary-keys / partition-keys keep backticks verbatim and fail to match column names that require SQL quoting Ran Tao (Jira)
• 2026/05/06 [jira] [Updated] (FLINK-39613) Flink cdc pipeline primary-keys / partition-keys keep backticks verbatim and fail to match column names that require SQL quoting Ran Tao (Jira)
• 2026/05/06 [jira] [Updated] (FLINK-39613) Flink cdc pipeline primary-keys / partition-keys keep backticks verbatim and fail to match column names that require SQL quoting Ran Tao (Jira)
• 2026/05/06 Re: [PR] Cross Language Unified Event [flink-agents] via GitHub
• 2026/05/06 [jira] [Updated] (FLINK-39613) Flink cdc pipeline primary-keys / partition-keys keep backticks verbatim and fail to match column names that require SQL quoting Ran Tao (Jira)
• 2026/05/06 [jira] [Updated] (FLINK-39613) Flink cdc pipeline primary-keys / partition-keys cannot resolve backtick-quoted identifiers Ran Tao (Jira)
• 2026/05/06 [jira] [Updated] (FLINK-39613) Flink cdc pipeline primary-keys / partition-keys cannot resolve backtick-quoted identifiers Ran Tao (Jira)
• 2026/05/06 [jira] [Assigned] (FLINK-39525) Release Testing: Verify FLIP-560: Application Capability Enhancement Yuepeng Pan (Jira)
• 2026/05/06 [jira] [Commented] (FLINK-39525) Release Testing: Verify FLIP-560: Application Capability Enhancement Yuepeng Pan (Jira)
• 2026/05/06 [jira] [Assigned] (FLINK-39525) Release Testing: Verify FLIP-560: Application Capability Enhancement Yuepeng Pan (Jira)
• 2026/05/06 [jira] [Commented] (FLINK-39493) Release Testing: Verify FLIP-549: Support Application Management Yuepeng Pan (Jira)
• 2026/05/06 [jira] [Assigned] (FLINK-39493) Release Testing: Verify FLIP-549: Support Application Management Yuepeng Pan (Jira)
• 2026/05/06 [jira] [Updated] (FLINK-39613) Flink cdc pipeline primary-keys / partition-keys cannot resolve backtick-quoted identifiers Ran Tao (Jira)
• 2026/05/06 Re: [PR] [hotfix] Fix flaky tests [flink] via GitHub
• 2026/05/06 Re: [PR] [hotfix] Fix flaky tests [flink] via GitHub
• 2026/05/06 Re: [PR] [hotfix] Fix flaky tests [flink] via GitHub
• 2026/05/06 [jira] [Assigned] (FLINK-39607) Add missing Nullable annotation and precondition for config Gabor Somogyi (Jira)
• 2026/05/06 Re: [PR] [FLINK-38244][hotfix] Fix the full snapshot phase, the field case is adjusted based on isTableIdCaseInsensitive [flink-cdc] via GitHub
• 2026/05/06 Re: [PR] [FLINK-14621][flink-table-planner] Do not generate watermark assigner operator if no time attribute operations on rowtime [flink] via GitHub
• 2026/05/06 Re: [PR] [FLINK-39603] Optimize NativeS3InputStream via seeks and reduce IOPS [flink] via GitHub
• 2026/05/06 Re: [PR] [hotfix][docs] Bump externalized connector docs refs to latest minor releases [flink] via GitHub
• 2026/05/06 Re: [PR] [hotfix][docs] Bump externalized connector docs refs to latest minor releases [flink] via GitHub
• 2026/05/06 Re: [PR] [Feature][Java] Add java event listeners config [flink-agents] via GitHub
• 2026/05/06 Re: [PR] [FLINK-39026][runtime] Remove misleading TODO about getPartitionedState overhead [flink] via GitHub
• 2026/05/06 Re: [PR] Fix the conversion to relational algebra issue in Batch Mode [flink] via GitHub
• 2026/05/06 Re: [PR] [hotfix] Adds Override annotation [flink] via GitHub
• 2026/05/06 Re: [PR] [hotfix]Adds Override annotation [flink] via GitHub
• 2026/05/06 Re: [PR] [hotfix] [pyflink] Fix Python Datastream JDBC Java method reference [flink] via GitHub
• 2026/05/06 Re: [PR] [hotfix] [docs] Rework 'Name and Description' section of operators overview to improve grammar and clarity [flink] via GitHub
• 2026/05/06 Re: [PR] [FLINK-38566] Support CEP DSL [flink] via GitHub
• 2026/05/06 Re: [PR] [FLINK-38584][metrics] Support checkpoint path as Prometheus info-style metric [flink] via GitHub
• 2026/05/06 Re: [PR] [hotfix] Tracks the number of pending manual compactions. [flink] via GitHub
• 2026/05/06 Re: [PR] [FLINK-38444][table] Join unique keys should not contain null values [flink] via GitHub
• 2026/05/06 Re: [PR] [FLINK-34251][core] ClosureCleaner to include reference classes for non-serialization exception [flink] via GitHub
• 2026/05/06 Re: [PR] [FLINK-38057][runtime] Fix the error value between getting and using idleStartTime in source reader metric group [flink] via GitHub
• 2026/05/06 Re: [PR] [FLINK-37771] Simplify getPartitionedState of AbstractKeyedStateBackend [flink] via GitHub
• 2026/05/06 Re: [PR] [runtime] Refactor ActionExecutionOperator into focused manager classes [flink-agents] via GitHub
• 2026/05/06 Re: [PR] [FLINK-37730][rest] Add client method for getting JM exception history [flink] via GitHub
• 2026/05/06 Re: [PR] [FLINK-37746] Added serialVersionUID in MapTypeInfo class [flink] via GitHub
• 2026/05/06 Re: [PR] [FLINK-36808][table-planner] Fix LookupJoin bug when used with filterable table source [flink] via GitHub
• 2026/05/06 Re: [PR] [hotfix] Avoid duplicate operation ! [flink] via GitHub
• 2026/05/06 Re: [PR] [FLINK-37716] Simplify YarnClusterDescriptor by removing parameter JobGraph [flink] via GitHub
• 2026/05/06 Re: [PR] [FLINK-37608][fs-connector] File sink supports to close buckets in parallel when snapshot [flink] via GitHub
• 2026/05/06 Re: [PR] [hotfix] Avoid invalid thread for state reader [flink] via GitHub
• 2026/05/06 Re: [PR] [FLINK-37521][table] Implement Proc/RowTimeIntervalJoin with async state [flink] via GitHub
• 2026/05/06 Re: [PR] [FLINK-37666]: Address CWE-378: Creation of Temporary File With Insec… [flink] via GitHub
• 2026/05/06 Re: [PR] [FLINK-37661] Remove Kryo serializer reference data from version 1.x [flink] via GitHub
• 2026/05/06 Re: [PR] [FLINK-35571][test] Can pass global test [flink] via GitHub
• 2026/05/06 Re: [PR] [FLINK-37655][runtime] Convert WindowStagger into an interface [flink] via GitHub
• 2026/05/06 Re: [PR] [hotfix] Rename loadJarFile to checkJarFile [flink] via GitHub
• 2026/05/06 Re: [PR] [FLINK-37637] Avoid dead lock for Configuration's addAll [flink] via GitHub
• 2026/05/06 Re: [PR] [hotfix] Remove the redundant config for execution target [flink] via GitHub
• 2026/05/06 Re: [PR] [INFRA-27887] Use pinned allowed versions for actions [flink-docker] via GitHub
• 2026/05/05 Re: [PR] [FLINK-37893][k8s] Make REST service port name configurable [flink] via GitHub
• 2026/05/05 [PR] [INFRA-27887] Use pinned allowed versions for actions [flink-docker] via GitHub
• 2026/05/05 [jira] [Updated] (FLINK-39613) Flink cdc pipeline primary-keys / partition-keys cannot resolve backtick-quoted identifiers that are used as projection aliases Ran Tao (Jira)
• 2026/05/05 [jira] [Created] (FLINK-39613) Flink pipeline cdc primary-keys / partition-keys cannot resolve backtick-quoted identifiers that are used as projection aliases Ran Tao (Jira)
• 2026/05/05 [jira] [Created] (FLINK-39612) [Model] Add HTTP connection pool management for Triton inference featzhang (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-39611) [Model] Add sequence ID auto-increment support for Triton inference featzhang (Jira)
• 2026/05/05 [jira] [Created] (FLINK-39611) [Model] Add sequence ID auto-increment support for Triton inference featzhang (Jira)
• 2026/05/05 [jira] [Commented] (FLINK-39472) Release Testing: Verify FLIP-555: Native S3 FileSystem Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Assigned] (FLINK-39472) Release Testing: Verify FLIP-555: Native S3 FileSystem Yuepeng Pan (Jira)
• 2026/05/05 Re: [PR] [FLINK-38753] [table-planner] Enrich upsert keys by equi-join equivalences [flink] via GitHub
• 2026/05/05 Re: [PR] [api][runtime][integration] Support Mem0 based Long-Term Memory on the Java side. [flink-agents] via GitHub
• 2026/05/05 [jira] [Created] (FLINK-39610) Mongo CDC connector supports specifying SSL context Xiqian Yu (Jira)
• 2026/05/05 Re: [PR] [FLINK-36779][table] Fix metric is incorrect and non-changing during the time in Rank [flink] via GitHub
• 2026/05/05 [PR] [api][runtime][integration] Support Mem0 based Long-Term Memory on the Java side. [flink-agents] via GitHub
• 2026/05/05 [jira] [Updated] (FLINK-36779) topn.cache.size metric is incorrect and non-changing during the time ASF GitHub Bot (Jira)
• 2026/05/05 Re: [I] [Feature][Python] Support Mem0 Long-Term Memory backend in Python. [flink-agents] via GitHub
• 2026/05/05 [PR] [FLINK-36779][table] Fix metric is incorrect and non-changing during the time in Rank [flink] via GitHub
• 2026/05/05 Re: [PR] [FLINK-39582][postgres] Allow logical messages [flink-cdc] via GitHub
• 2026/05/05 [jira] [Commented] (FLINK-39472) Release Testing: Verify FLIP-555: Native S3 FileSystem Xiqian Yu (Jira)
• 2026/05/05 Re: [PR] [FLINK-39228][starrocks] Escape quoted default/comment literals in DDL [flink-cdc] via GitHub
• 2026/05/05 Re: [PR] [FLINK-39036][formats] Honor microsecond Avro logical types in RowDataToAvroConverters [flink] via GitHub
• 2026/05/05 [jira] [Resolved] (FLINK-39502) Performance regression in remoteSortPartition and compressedFilePartition David Anderson (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-39502) Performance regression in remoteSortPartition and compressedFilePartition David Anderson (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-36489) Remove deprecated method `StreamTableEnvironment#toRetractStream` Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-37248) Scala was removed in flink 2.0 Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-37340) Flink supports pushing metrics immediately at the end of the task. Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-38225) GSBlobStorageImpl needs to add precondition check to make 503 retryable Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-37549) Some scala and markdown syntax errors in tableApi page Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-38228) To ensure consistent aggregation results in the window operator, we need to consider state TTL; otherwise, we must send messages to downstream operators to prevent their state from expiring prematurely. Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-37431) We should use guava Lists instead of curator shade Lists to avoid unnecessary error Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-37413) Introduce append-only RowTimeDeduplicateFunction with Async State API Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-37404) Reenable Migration Tests for Filnk 2.x Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-38516) Add configuration option to enable read-only mode for Flink SQL Gateway Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-38321) Optimize the timer registration logic n window early/late firing scenarios Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-38172) Update japicmp configuration Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-38151) Class MetricFetcherImpl's method fetchMetrics failed log level adjustment to error Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-38223) ExecutionGraphRestartTest and ExecutionGraphCoLocationRestartTest are flaky on master Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-38510) Remove targetColumns from the digest generation of SinkReuser Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-38468) Performance drops when the coalesce parameter includes functions Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-38463) Support TTL in SinkUpsertMaterializerV2 Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-38335) SplitEnumeratorContext supports fixed delay async call. Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Commented] (FLINK-38225) GSBlobStorageImpl needs to add precondition check to make 503 retryable Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-38071) FLIP-485: Add UDF Metrics Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-37477) Emit full deletes from StreamJoin if it gets deletes on key on input Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-37442) Properly delete the directories for ForSt remote storage Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-38120) FLIP-536 Add latest checkpoint details endpoint Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-37732) FLIP-527: State Schema Evolution for RowData Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-37624) Support enableAsyncState and switch operator after datastream transformation Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-37854) UnsupportedTemporalTypeException: Unsupported field: OffsetSeconds Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-37777) FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-37551) Improve the state compatibility of ForStKeyeStateBackend and ForStSyncKeyeStateBackend Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-37608) File sink supports to close buckets in parallel when snapshot Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-37593) Add Some Reduce Expression Rules Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Commented] (FLINK-37554) Add unit tests for state compatibility between ForStKeyeStateBackend and ForStSyncKeyeStateBackend Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-37554) Add unit tests for state compatibility between ForStKeyeStateBackend and ForStSyncKeyeStateBackend Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-37526) Promote SinkV2 API classes from @Experimental to @PublicEvolving Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-37117) Add docs for async state SQL operators in 2.0 Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-37088) When the Flink application is running in k8s, the taskmanager log lacks a mount mapping to the host machine. Once the container is restarted, the log will disappear. It is necessary to have a log mount mapping to the host machine Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-36665) WINDOW_START, WINDOW_END always return TIMESTAMP(3) Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-37103) The argument lists of the method FactoryUtil.createDynamicTableSink are inconsistent. Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-36953) FLIP-497: Early Fire Support for Flink SQL Interval Join Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-36505) Remove all deprecated methods in `ImperativeAggregateFunction`, `ScalarFunction` and `TableFunction` Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-36660) Release flink-connector-elasticsearch v4.0.0 for Flink 2.0 Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-36658) Support and Release Connectors for Flink 2.0 Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-36498) Remove deprecated method `ResolvedCatalogBaseTable#getSchema` Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-36495) Remove deprecated method `CatalogBaseTable#getSchema` Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-38551) Extend MultiJoin tests based on current join tests Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-38570) FLIP-554: Pipeline Testing Framework for Flink Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-38595) Extend MultiJoin tests for further validation Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-36399) cast result is incorrect Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-36482) Remove all deprecated methods in `TableEnvironment` Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-36488) Remove deprecated method `StreamTableEnvironment#toAppendStream` Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-36485) Remove deprecated method `StreamTableEnvironment#fromDataStream` Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-36487) Remove deprecated method `StreamTableEnvironment#createTemporaryView` Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-36381) Remove legacy csv source/sink in python module Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-36378) type extraction problem between java BigDecimal and sql decimal Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Commented] (FLINK-36378) type extraction problem between java BigDecimal and sql decimal Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-36479) Remove deprecated methods `Table#getSchema` and `Table#as` Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-36413) Reenable the test case that related to Source/Sink APi deprecated. Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-36186) Speed up RocksDB close during manual compaction Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-36378) Fix type extraction bug between java BigDecimal and sql decimal. Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-36378) type extraction problem between java BigDecimal and sql decimal Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Resolved] (FLINK-36378) Fix type extraction bug between java BigDecimal and sql decimal. Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-36354) Enable FORSTDB_BACKEND in async releated tests Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-36363) Remove references to scala-relate api in tests among table modules Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-36290) OutOfMemoryError in connect test run Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Commented] (FLINK-36352) [FLINK-36352][doc] Remove Scala DataStream API related doc Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Resolved] (FLINK-36352) [FLINK-36352][doc] Remove Scala DataStream API related doc Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-36352) [FLINK-36352][doc] Remove Scala DataStream API related doc Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-36352) [FLINK-36352][doc] Remove Scala DataStream API related doc Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-36334) Remove the Disable markers from the tests in the various TypeSerializerUpgradeTestBase subclasses in flink-table-api-scala module Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-36352) [FLINK-36352][doc] Remove Scala DataStream API related doc Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-36339) Remove java serialization from SQL serializers Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-36291) java.lang.IllegalMonitorStateException causing a fatal error on the TaskManager side Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-36160) Support hive advanced configuration Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-36135) Remove the TableSource and TableSink ecosystem APIs like TableFactory, DefinedFieldMapping, FilterableTableSource, etc. Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-36136) Remove TableSource & TableSink impl and utils, docs and etc. Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-35206) Desc table syntax support materialized table Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Commented] (FLINK-35761) FLIP-547: Support checkpoint during recovery Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-35769) State files might not be deleted on task cancellation Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-36134) Remove the classes associated with TableSource and TableSink as part of the optimization process. Yuepeng Pan (Jira)
• 2026/05/05 [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/05/05 [jira] [Updated] (FLINK-36008) Guidance for previewing connector docs contributions Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-36133) Remove subclass implementations of TableSource and TableSink, along with their corresponding Factory classes. Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-35970) Update documentation about FLINK-26050 (merging small SST files) Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-35698) Parquet connector fails to load ROW<x decimal(5, 2)> after save Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-35688) Add materialized table develop guide docs Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-35657) Flink UI not support show float metric value Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-35311) FLIP-454: New Apicurio Avro format Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-35737) Prevent Memory Leak by Closing MemoryExecutionGraphInfoStore on MiniCluster Shutdown Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-35326) Implement lineage interface for hive connector Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-35315) MemoryManagerConcurrentModReleaseTest executes more than 15 minutes Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-35657) Flink UI not support show float metric value Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-35657) Flink UI not support show float metric value Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Resolved] (FLINK-35657) Flink UI not support show float metric value Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Commented] (FLINK-35657) Flink UI not support show float metric value Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-35557) MemoryManager only reserves memory per consumer type once Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-35573) [FLIP-447] Upgrade FRocksDB from 6.20.3 to 8.10.0 Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-35582) Marking ingestDB as the default recovery mode for rescaling Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-35535) Enable benchmark profiling in daily run Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-35327) SQL Explain show push down condition Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Commented] (FLINK-35534) Support profiler for benchmarks Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-35644) Add materialized table user guide doc Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-35534) Support profiler for benchmarks Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-35529) protobuf-format compatible protobuf bad indentifier Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-35481) Add HISTOGRAM function in SQL & Table API Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-35166) Improve the performance of Hybrid Shuffle when enable memory decoupling Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-35480) Add FIELD function in SQL & Table API Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-35163) Utilize ForSt's native MultiGet API to optimize remote state access Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Created] (FLINK-39609) update Dynamic Kafka Source doc with new python/sql examples and other improvement details Bowen Li (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-35145) Add timeout for cluster termination Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-35103) [Plugin] Enhancing Flink Failure Management in Kubernetes with Dynamic Termination Log Integration Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Commented] (FLINK-34982) FLIP-428: Fault Tolerance/Rescale Integration for Disaggregated State Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-34982) FLIP-428: Fault Tolerance/Rescale Integration for Disaggregated State Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-34670) The asyncOperationsThreadPool in SubtaskCheckpointCoordinatorImpl can only create one worker thread Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-34665) Add streaming rule for union to Rand and it convert to StreamExecDeduplicate finally Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-34611) Migrate StreamPhysicalUnionRule Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-34421) Skip post-compile checks in compile.sh if fast profile is active Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-34612) Migrate StreamPhysicalValuesRule Yuepeng Pan (Jira)
• 2026/05/05 [jira] [Updated] (FLINK-34973) FLIP-425: Asynchronous Execution Model Yuepeng Pan (Jira)

• Earlier messages
• Later messages