issues  

Messages by Date

• 2026/05/04 [jira] [Updated] (FLINK-31098) Add ARRAY_SIZE supported in SQL & Table API Sergey Nuyanzin (Jira)
• 2026/05/04 [jira] [Closed] (FLINK-39561) Extend sensitive key redaction with missing access key patterns and user-configurable additional keys Gabor Somogyi (Jira)
• 2026/05/04 [jira] [Resolved] (FLINK-39561) Extend sensitive key redaction with missing access key patterns and user-configurable additional keys Gabor Somogyi (Jira)
• 2026/05/04 [jira] [Commented] (FLINK-39561) Extend sensitive key redaction with missing access key patterns and user-configurable additional keys Gabor Somogyi (Jira)
• 2026/05/04 Re: [PR] [FLINK-39561][security] Extend sensitive key redaction with missing access key patterns and user-configurable additional keys [flink] via GitHub
• 2026/05/04 [jira] [Updated] (FLINK-14383) Support python UDFs with constant value of time interval types Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-15183) Use SQL-CLI to TPC-DS E2E test Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-15003) Improve hive test performance Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-14148) Investigate pushing predicate/projection to underlying Hive input format Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-14340) Specify an unique DFSClient name for Hadoop FileSystem Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-14222) Optimize for Python UDFs with all parameters are constant values Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-14125) Display memory and CPU usage in the overview page Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-14028) Support to configure the log level of the Python user-defined functions Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-13928) Make windows api more extendable Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-15351) develop PostgresCatalog to connect Flink with Postgres tables and ecosystem Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-14122) Extend State Processor API to read ListCheckpointed operator state Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-13735) Support session window with blink planner in batch mode Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-15471) HA e2e check for empty .out files does not print specific error Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-15460) planner dependencies won't be necessary for JDBC connector Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-12692) Support disk spilling in HeapKeyedStateBackend Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-12491) Incorrect documentation for directory path separators of CoreOptions.TMP_DIRS Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-13015) Create validators, strategies and transformations required for porting logical expressions Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-12352) [FLIP-36] [Phase 1] Support cache() / invalidateCache() in Table with default ShuffleService and NetworkStack Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-12590) Replace http links in documentation Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-12273) The default value of CheckpointRetentionPolicy should be RETAIN_ON_FAILURE, otherwise it cannot be recovered according to checkpoint after failure. Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-11937) Resolve small file problem in RocksDB incremental checkpoint Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-11868) [filesystems] Introduce listStatusIterator API to file system Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-11409) Make `ProcessFunction`, `ProcessWindowFunction` and etc. pure interfaces Yuepeng Pan (Jira)
• 2026/05/04 Re: [PR] [FLINK-38544] Allocate pre-filter source buffers from heap in filtering mode [flink] via GitHub
• 2026/05/04 [jira] [Updated] (FLINK-15532) Enable strict capacity limit for memory usage for RocksDB Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-15553) Create table ddl support comment after computed column Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-10374) [Map State] Let user value serializer handle null values Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-10113) Drop support for pre 1.6 shared buffer state Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-36843) Remove deprecated method in flink-table-planner Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-36851) Introduce TemporalProcessTimeJoinOperator in TemporalJoin with Async State API Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-36911) add more calcite rules to improve flink performance because calcite has upgrade Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-36849) Introduce AppendOnlyFirstNFunction in Rank with Async State API Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-36882) Introduce MiniBatchGroupAggFunction in GroupAggregate with Async State API Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-36881) Introduce GroupTableAggFunction in GroupTableAggregate with Async State API Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-36869) Introduce TemporalRowTimeJoinOperator in TemporalJoin with Async State API Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-36880) Hybrid Shuffle support batch job recovery Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-9879) Find sane defaults for (advanced) SSL session parameters Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-26949) Add NVL supported in SQL & Table API Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-26944) Add ADD_MONTHS supported in SQL and Table API Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-22484) Built-in functions for collections Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-26945) Add DATE_SUB supported in SQL & Table API Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-6810) Add a set of built-in functions to Table API & SQL Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-31098) Add ARRAY_SIZE supported in SQL & Table API Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-5346) Remove all ad-hoc config loading via GlobalConfiguration Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-38351) Docker images support OpenJDK Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-38233) Implement visitProcessTableFunction for StreamNonDeterministicUpdatePlanVisitor Yuepeng Pan (Jira)
• 2026/05/04 [PR] [FLINK-38544] Allocate pre-filter source buffers from heap in filtering mode [flink] via GitHub
• 2026/05/04 [jira] [Updated] (FLINK-38444) Join calculates upsert keys with null keys for left join Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-38392) StreamPandasConversionTests failing Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-38459) SinkUpsertMaterializer V2 (FLIP-544) Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-37064) Validate Schema Column Name Conflicts in Definition Query During Materialized Table Creation or Alter Query Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Closed] (FLINK-38764) switch lz4-java to at.yawk.lz4 version due to CVE Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-38980) Migrate RemoveRedundantLocalSortAggRule Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-38942) Add documentation for async python scalar function Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-38992) Defining a state ttl on NonTime Over Windows leads to NullPointerException Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-39166) Add bucket level config parity Yuepeng Pan (Jira)
• 2026/05/04 Re: [PR] [hotfix][ci] Ignore GHA build on non-code changes [flink] via GitHub
• 2026/05/04 [jira] [Updated] (FLINK-39396) Simplify early return condition in SqlLikeChainChecker.check() Yuepeng Pan (Jira)
• 2026/05/04 [jira] [Updated] (FLINK-39422) [FLINK][OpenAPI] OpenApiSpecGenerator produces incorrect schemas for types with custom Jackson serializers Yuepeng Pan (Jira)
• 2026/05/04 Re: [PR] [hotfix][ci] Ignore GHA build on non-code changes [flink] via GitHub
• 2026/05/04 Re: [PR] [hotfix][ci] Ignore GHA build on non-code changes [flink] via GitHub
• 2026/05/04 Re: [PR] [hotfix] Fix flaky tests [flink] via GitHub
• 2026/05/04 Re: [PR] [hotfix][ci] Ignore GHA build on non-code changes [flink] via GitHub
• 2026/05/04 [PR] [hotfix] Fix flaky tests [flink] via GitHub
• 2026/05/04 [PR] [hotfix][ci] Ignore GHA build on non-code changes [flink] via GitHub
• 2026/05/04 Re: [PR] [BP-2.3][FLINK-39595][ci] Use GHA cache per branch [flink] via GitHub
• 2026/05/04 Re: [PR] [BP-2.0][FLINK-39595][ci] Use GHA cache per branch [flink] via GitHub
• 2026/05/04 Re: [PR] [BP-1.20][FLINK-39595][ci] Use GHA cache per branch [flink] via GitHub
• 2026/05/04 Re: [PR] [BP-2.2][FLINK-39595][ci] Use GHA cache per branch [flink] via GitHub
• 2026/05/04 Re: [PR] [BP-2.1][FLINK-39595][ci] Use GHA cache per branch [flink] via GitHub
• 2026/05/04 [PR] Flink Kubernetes Operator 1.15.0 [flink-web] via GitHub
• 2026/05/04 [PR] [BP-1.20][FLINK-39595][ci] Use GHA cache per branch [flink] via GitHub
• 2026/05/04 [PR] [BP-2.0][FLINK-39595][ci] Use GHA cache per branch [flink] via GitHub
• 2026/05/04 [PR] [BP-2.1][FLINK-39595][ci] Use GHA cache per branch [flink] via GitHub
• 2026/05/04 [PR] [BP-2.3][FLINK-39595][ci] Use GHA cache per branch [flink] via GitHub
• 2026/05/04 [PR] [BP-2.2][FLINK-39595][ci] Use GHA cache per branch [flink] via GitHub
• 2026/05/04 [jira] [Commented] (FLINK-39595) Use GHA cache per branch Sergey Nuyanzin (Jira)
• 2026/05/04 Re: [PR] [FLINK-39595][ci] Use GHA cache per branch [flink] via GitHub
• 2026/05/04 Re: [PR] [FLINK-32212][runtime] Fix infinite restart loop from BlobLibraryCach… [flink] via GitHub
• 2026/05/04 Re: [PR] [FLINK-39595][ci] Use GHA cache per branch [flink] via GitHub
• 2026/05/04 Re: [PR] [FLINK-39595][ci] Use GHA cache per branch [flink] via GitHub
• 2026/05/04 Re: [PR] [FLINK-39595][ci] Use GHA cache per branch [flink] via GitHub
• 2026/05/04 Re: [PR] [FLINK-39595][ci] Use GHA cache per branch [flink] via GitHub
• 2026/05/04 Re: [PR] [FLINK-39595][ci] Use GHA cache per branch [flink] via GitHub
• 2026/05/04 [jira] [Updated] (FLINK-39599) Expose pendingRecords metrics in FLINK Kinesis Connector ASF GitHub Bot (Jira)
• 2026/05/04 [PR] [FLINK-39599][Connectors/Kinesis] Emit pendingRecords metric in Kinesis connector. [flink-connector-aws] via GitHub
• 2026/05/04 Re: [PR] [FLINK-39599][Connectors/Kinesis] Emit pendingRecords metric in Kinesis connector. [flink-connector-aws] via GitHub
• 2026/05/04 Re: [PR] [FLINK-39377][table] Add initial implementation of ProcessTableFunctionTestHarness [flink] via GitHub
• 2026/05/04 Re: [PR] [FLINK-39595][ci] Use GHA cache per branch [flink] via GitHub
• 2026/05/04 Re: [PR] [hotfix][docs] Bump externalized connector docs refs to latest minor releases [flink] via GitHub
• 2026/05/04 Re: [PR] Bump com.squareup.okhttp3:okhttp from 3.7.0 to 4.10.0.redhat-00002 in /flink-runtime [flink] via GitHub
• 2026/05/04 Re: [PR] [hotfix] Intermittent unit test failures we have hit in ExecutionGraph tests [flink] via GitHub
• 2026/05/04 Re: [PR] [FLINK-38569][table-planner] Avoid generating ReadingMetadataSpec when no metadata [flink] via GitHub
• 2026/05/04 Re: [PR] Bump com.squareup.okhttp3:okhttp from 3.7.0 to 4.10.0.redhat-00002 [flink] via GitHub
• 2026/05/04 Re: [PR] [FLINK-38946][flink-metrics] Allow AWS PrivateLink/GCP Cloud Private Service Connect for Datadog integration [flink] via GitHub
• 2026/05/04 Re: [PR] [hotfix] Unify the name for the collection of SlotOffer with slotOffers [flink] via GitHub
• 2026/05/04 Re: [PR] [FLINK-38569][table-planner] Avoid generating ReadingMetadataSpec when no metadata [flink] via GitHub
• 2026/05/04 Re: [PR] Bump com.squareup.okhttp3:okhttp from 3.7.0 to 4.10.0.redhat-00002 in /flink-runtime [flink] via GitHub
• 2026/05/04 Re: [PR] [hotfix] Rename registeredSlots to allocatedSlots [flink] via GitHub
• 2026/05/04 Re: [PR] Bump com.squareup.okhttp3:okhttp from 3.7.0 to 4.10.0.redhat-00002 [flink] via GitHub
• 2026/05/04 Re: [PR] Bump com.squareup.okhttp3:okhttp from 3.7.0 to 4.10.0.redhat-00002 in /flink-runtime [flink] via GitHub
• 2026/05/04 Re: [PR] Bump com.squareup.okhttp3:okhttp from 3.7.0 to 4.10.0.redhat-00002 [flink] via GitHub
• 2026/05/04 Re: [PR] [hotfix] Simplify the calling on addShutdownHook [flink] via GitHub
• 2026/05/03 Re: [PR] [FLINK-39042][webui] Make watermark timestamps timezone-aware and configurable [flink] via GitHub
• 2026/05/03 [jira] [Updated] (FLINK-39599) Expose pendingRecords metrics in FLINK Kinesis Connector David (Jira)
• 2026/05/03 [jira] [Created] (FLINK-39599) Expose pendingRecords metrics in FLINK Kinesis Connector David (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-39598) Update jline to 3.30.12 Sergey Nuyanzin (Jira)
• 2026/05/03 [jira] [Resolved] (FLINK-39598) Update jline to 3.30.12 Sergey Nuyanzin (Jira)
• 2026/05/03 Re: [PR] [FLINK-39598][table] Update jline to 3.30.12 [flink] via GitHub
• 2026/05/03 [jira] [Commented] (FLINK-39598) Update jline to 3.30.12 Sergey Nuyanzin (Jira)
• 2026/05/03 Re: [PR] [hotfix][docs] Fix incorrect HashMapStateBackend recommendations [flink] via GitHub
• 2026/05/03 [jira] [Updated] (FLINK-13910) Many serializable classes have no explicit 'serialVersionUID' Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-14867) Move TextInputFormat & TextOutputFormat to flink-core Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-14410) Retrieve CharacterFilter once after registration Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-12358) Verify whether rest documenation needs to be updated when building pull request Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-17011) Introduce builder to create AbstractStreamOperatorTestHarness for testing Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-12412) Allow ListTypeInfo used for java.util.List and MapTypeInfo used for java.util.Map Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-14351) Refactor MetricRegistry delimiter retrieval into separate interface Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-18201) Support create_function in Python Table API Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-15018) Add event time page to Concepts Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-18986) KubernetesSessionCli creates RestClusterClient for detached deployments Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-16952) Parquet file system format support filter pushdown Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-21634) ALTER TABLE statement enhancement Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-21375) Refactor HybridMemorySegment Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-22909) Supports change log inputs for event time operators Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-22956) Stream Over TTL should use enableTimeToLive of state instead of timer Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-21783) Allow HeapBackend snapshotting customization Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-21784) Allow HeapBackend RestoreOperation customization Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-21649) Allow extension of CopyOnWrite state classes Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-22240) Sanity/phrasing pass for ExternalResourceUtils Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-39511) FLIP-514: Custom Evaluator plugin for Flink Autoscaler Gyula Fora (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-39565) Eliminate maven build warnings across all modules Gyula Fora (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-39549) Compute OBSERVED_TPR for non-source vertices behind a feature flag for Operator Autoscaler Gyula Fora (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-39370) In-place scaling check only inspects K8s resource spec for adaptive scheduler, ignoring JM running configuration Gyula Fora (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-39390) Add Extensibility to Autoscaler Components via the Plugin Mechanism Gyula Fora (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-39306) Non-source vertices do not use per-second rate metrics, producing inaccurate scaling decisions Gyula Fora (Jira)
• 2026/05/03 Re: [PR] [hotfix] Add missing compatibility checks [flink-kubernetes-operator] via GitHub
• 2026/05/03 Re: [PR] [hotfix] [docs] Fix broken flink-training links in hands-on section [flink] via GitHub
• 2026/05/03 [jira] [Updated] (FLINK-23000) Allow downloading all Flink logs from the UI Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-23589) Support Avro Microsecond precision Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-26081) Update document,becasue of add maven wrapper. Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-23815) Separate the concerns of PendingCheckpoint and CheckpointPlan Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-26963) Allow HeapBackend creation customization Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-26964) Notify CheckpointStrategy about checkpoint completion/abortion Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-26965) Allow reuse of PeriodicMaterializationManager Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-26967) Fix race condition in CopyOnWriteStateMap Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-27391) Support Hive bucket table Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-28071) Support missing built-in functions in Table API Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-26968) Bump CopyOnWriteStateMap entry version before write Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-27242) Support RENAME PARTITION statement for partitioned table Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-27603) Hive dialect supports "reload function" Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-27467) Remove CliFrontendTestBase Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-28985) support create table like view Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-31316) FLIP-291: Externalized Declarative Resource Management Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-31757) FLIP-370: Support Balanced Tasks Scheduling Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-30578) Publish SBOM artifacts Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-32070) FLIP-306 Unified File Merging Mechanism for Checkpoints Yuepeng Pan (Jira)
• 2026/05/03 [PR] [hotfix] Add missing compatibility checks [flink-kubernetes-operator] via GitHub
• 2026/05/03 [jira] [Updated] (FLINK-29866) Split flink-dist Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-29813) Remove deprecated Curator API usages Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-31518) HighAvailabilityServiceUtils resolves wrong webMonitorAddress in Standalone mode Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-32179) Handle more repo names for automatic dist discovery Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-32181) Drop support for Maven 3.2.5 Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-32239) Unify TestJvmProcess and TestProcessBuilder Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-33319) Add AverageTime metric to measure delta change in GC time Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-33557) Externalize Cassandra Python connector code Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-34004) TestingCheckpointIDCounter can easily lead to NPEs Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-34064) FLIP-417: Expose JobManagerOperatorMetrics via REST API Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-34134) Add tracing for restored state size and locations Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-32437) Determine and set correct maxParallelism for operator chains Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Commented] (FLINK-34415) Move away from Kafka-Zookeeper based tests in favor of Kafka-KRaft Taranpreet Kaur (Jira)
• 2026/05/03 Re: [PR] [FLINK-39361][connector-http] Improve README with SQL examples [flink-connector-http] via GitHub
• 2026/05/03 Re: [PR] [FLINK-39368][connector-http] Add User-Agent configuration support for HTTP sink and lookup [flink-connector-http] via GitHub
• 2026/05/03 [jira] [Updated] (FLINK-34255) FLIP-406: Reorganize State & Checkpointing & Recovery Configuration Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-34559) TVF Window Aggregations might get stuck Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-34975) FLIP-427: ForSt - Disaggregated State Store Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-34974) FLIP-424: Asynchronous State APIs Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-36132) Remove codes that references TableSource and TableSink directly at the API level. Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-37836) FLIP-486 Introduce a new DeltaJoin Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-35187) FLIP-435: Introduce a New Materialized Table for Simplifying Data Pipelines Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-37403) Support retractions/updates for IntervalJoin operator Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-36733) Don't transition task to RUNNING until the inputs are recovered (UC) Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-39322) Add some restore tests about cascaded delta join Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-39322) Add some restore tests about cascaded delta join Yuepeng Pan (Jira)
• 2026/05/03 [jira] [Updated] (FLINK-38770) pipeline.jobvertex-parallelism-overrides ignored for StreamGraph in Application Mode Yuepeng Pan (Jira)
• 2026/05/03 Re: [PR] [FLINK-39557] Generate correct Multi-Release JAR files for Jackson and Swagger [flink-shaded] via GitHub
• 2026/05/03 [jira] [Commented] (FLINK-39591) Bump actions v4 to v5 Sergey Nuyanzin (Jira)
• 2026/05/03 Re: [PR] [FLINK-39591][ci] Bump actions@checkout, actions@download, actions@upload-artifact, actions@setup-python [flink] via GitHub
• 2026/05/03 [jira] [Resolved] (FLINK-39591) Bump actions v4 to v5 Sergey Nuyanzin (Jira)
• 2026/05/03 Re: [PR] [FLINK-39591][ci] Bump actions@checkout, actions@download, actions@upload-artifact, actions@setup-python [flink] via GitHub
• 2026/05/03 Re: [PR] [FLINK-39281] Flink Connector redis stream Source [flink-connector-redis-streams] via GitHub
• 2026/05/03 Re: [PR] [FLINK-39281] Flink Connector redis stream Source [flink-connector-redis-streams] via GitHub
• 2026/05/03 Re: [PR] [FLINK-39281] Flink Connector redis stream Source [flink-connector-redis-streams] via GitHub
• 2026/05/03 Re: [PR] [FLINK-39281] Flink Connector redis stream Source [flink-connector-redis-streams] via GitHub
• 2026/05/03 Re: [PR] [FLINK-39281] Flink Connector redis stream Source [flink-connector-redis-streams] via GitHub

• Earlier messages