issues

Messages by Date

2026/10/30 [jira] [Updated] (FLINK-25444) ClosureCleaner rejects ExecutionConfig as not be Serializable due to TextElement Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-24688) yarn.application-attempt-failures-validity-interval link url is invalid Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34605) Migrate BatchPhysicalDistributionRule Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34611) Migrate StreamPhysicalUnionRule Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-36133) Remove subclass implementations of TableSource and TableSink, along with their corresponding Factory classes. Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34981) FLIP-426: Grouping Remote State Access Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-35311) FLIP-454: New Apicurio Avro format Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34611) Migrate StreamPhysicalUnionRule 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] [Updated] (FLINK-35145) Add timeout for cluster termination Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-26692) migrate TpcdsTestProgram.java to new source Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-26477) Finalize the window support in Python DataStream API Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34559) TVF Window Aggregations might get stuck Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-24757) Yarn application is not terminated after the job finishes when submitting a yarn-per-job insert job with SQL client Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-35529) protobuf-format compatible protobuf bad indentifier Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34618) Migrate SplitPythonConditionFromJoinRule Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-35582) Marking ingestDB as the default recovery mode for rescaling Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34665) Add streaming rule for union to Rand and it convert to StreamExecDeduplicate finally Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34607) Migrate BatchPhysicalUnionRule Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-35206) Desc table syntax support materialized table Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-35534) Support profiler for benchmarks Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-35481) Add HISTOGRAM function in SQL & Table API Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34974) FLIP-424: Asynchronous State APIs Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34453) [Benchmark] Add warmup in SchedulerBenchmarkExecutor Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-35535) Enable benchmark profiling in daily run Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34973) FLIP-425: Asynchronous Execution Model 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-34603) Migrate BatchPhysicalBoundedStreamScanRule Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-36008) Guidance for previewing connector docs contributions Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34608) Migrate BatchPhysicalValuesRule Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34973) FLIP-425: Asynchronous Execution Model Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-35769) State files might not be deleted on task cancellation Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-35326) Implement lineage interface for hive connector Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-35311) FLIP-454: New Apicurio Avro format Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34609) Migrate BatchPhysicalScriptTransformRule Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-33557) Externalize Cassandra Python connector code Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-33894) Implement restore tests for PythonGroupAggregate node Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-40584) Bound RocksDB prefix iterators to avoid scanning unrelated tombstones 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-22926) IDLE FLIP-27 source should go ACTIVE when registering a new split Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34603) Migrate BatchPhysicalBoundedStreamScanRule Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-29813) Remove deprecated Curator API usages Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34255) FLIP-406: Reorganize State & Checkpointing & Recovery Configuration Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34604) Migrate BatchPhysicalCalcRule Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34604) Migrate BatchPhysicalCalcRule Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-33893) Implement restore tests for PythonCorrelate node 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-32699) select typeof(proctime()); throw exception in sql-client Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-30087) sql-gateway-api is bundled twice in the distribution 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-34981) FLIP-426: Grouping Remote State Access Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-38980) Migrate RemoveRedundantLocalSortAggRule Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-30246) Registering the same metric object with different name and group will conflict in metric reporter Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-35557) MemoryManager only reserves memory per consumer type once Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-36665) WINDOW_START, WINDOW_END always return TIMESTAMP(3) 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-34618) Migrate SplitPythonConditionFromJoinRule Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34605) Migrate BatchPhysicalDistributionRule 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-34445) Integrate new endpoint with Flink UI metrics section Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-36880) Hybrid Shuffle support batch job recovery Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-36399) cast result is incorrect Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-36133) Remove subclass implementations of TableSource and TableSink, along with their corresponding Factory classes. Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34559) TVF Window Aggregations might get stuck Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-35582) Marking ingestDB as the default recovery mode for rescaling Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-36498) Remove deprecated method `ResolvedCatalogBaseTable#getSchema` Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-40883) Accumulator corruption in NonTimeRowsUnboundedPrecedingFunction Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-41202) Make connector integrations easier to find from the Flink docs Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-36505) Remove all deprecated methods in `ImperativeAggregateFunction`, `ScalarFunction` and `TableFunction` Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34612) Migrate StreamPhysicalValuesRule Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-39404) HardwareDescription reports incorrect CPU cores in containerized environments with fractional CPU limits Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-40735) OVER window ordered by a non-time attribute fails for LAG and ARRAY_AGG when a row arrives out of order Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-36479) Remove deprecated methods `Table#getSchema` and `Table#as` Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-36495) Remove deprecated method `CatalogBaseTable#getSchema` 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-35326) Implement lineage interface for hive connector Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-37608) File sink supports to close buckets in parallel when snapshot Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-36658) Support and Release Connectors for Flink 2.0 Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-39285) Consider the result of filter pushdown rules in the MultiJoin rule Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-40267) CREATE MATERIALIZED TABLE skips persisted-metadata-column validation applied by CREATE OR ALTER Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34473) Migrate FlinkPruneEmptyRules Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-38151) Class MetricFetcherImpl's method fetchMetrics failed log level adjustment to error Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-35481) Add HISTOGRAM function in SQL & Table API 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-35187) FLIP-435: Introduce a New Materialized Table for Simplifying Data Pipelines Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-36485) Remove deprecated method `StreamTableEnvironment#fromDataStream` Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-36733) Don't transition task to RUNNING until the inputs are recovered (UC) Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-39545) Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34453) [Benchmark] Add warmup in SchedulerBenchmarkExecutor Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-39535) Improve Unit Test & coverage Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-39322) Add some restore tests about cascaded delta join Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34609) Migrate BatchPhysicalScriptTransformRule Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-40751) State Processor environment and operators should use task memory/io manager Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-38321) Optimize the timer registration logic n window early/late firing scenarios Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-35535) Enable benchmark profiling in daily run Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-35557) MemoryManager only reserves memory per consumer type once Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-39700) Fix name-based column matching in materialized table schema diff Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34981) FLIP-426: Grouping Remote State Access Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-35145) Add timeout for cluster termination Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-37413) Introduce append-only RowTimeDeduplicateFunction with Async State API Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-38992) Defining a state ttl on NonTime Over Windows leads to NullPointerException Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-36849) Introduce AppendOnlyFirstNFunction in Rank with Async State API Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-35769) State files might not be deleted on task cancellation Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-38551) Extend MultiJoin tests based on current join tests Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34618) Migrate SplitPythonConditionFromJoinRule Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-36488) Remove deprecated method `StreamTableEnvironment#toAppendStream` 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-37064) Validate Schema Column Name Conflicts in Definition Query During Materialized Table Creation or Alter Query Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-36660) Release flink-connector-elasticsearch v4.0.0 for Flink 2.0 Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-36133) Remove subclass implementations of TableSource and TableSink, along with their corresponding Factory classes. Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-37442) Properly delete the directories for ForSt remote storage Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-39924) Memory fragmentation from jemalloc misconfiguration Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-38516) Add configuration option to enable read-only mode for Flink SQL Gateway Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-39947) Fix the flaky test case in class TaskExecutorPartitionLifecycleTest Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-37248) Scala was removed in flink 2.0 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-34606) Migrate BatchPhysicalExpandRule Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34665) Add streaming rule for union to Rand and it convert to StreamExecDeduplicate finally Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-41119) Prepare Flink 2.4 release Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34603) Migrate BatchPhysicalBoundedStreamScanRule Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-36869) Introduce TemporalRowTimeJoinOperator in TemporalJoin with Async State API Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-40301) Adjacent Calc nodes created by watermark transposition prevent projection pushdown through ChangelogNormalize 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-36008) Guidance for previewing connector docs contributions Yuepeng Pan (Jira)
2026/10/30 [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/10/30 [jira] [Updated] (FLINK-36135) Remove the TableSource and TableSink ecosystem APIs like TableFactory, DefinedFieldMapping, FilterableTableSource, etc. Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-40303) Sink constraint enforcer rejects key-only DELETE records with NOT NULL non-key columns Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-39109) [Phase 2] Native s3 Filesystem 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-34610) Migrate StreamPhysicalLimitRule Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-37403) Support retractions/updates for IntervalJoin operator Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-38510) Remove targetColumns from the digest generation of SinkReuser Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-35644) Add materialized table user guide doc Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34605) Migrate BatchPhysicalDistributionRule Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-36136) Remove TableSource & TableSink impl and utils, docs and etc. Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-37155) FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch Yuepeng Pan (Jira)
2026/10/30 [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/10/30 [jira] [Updated] (FLINK-37624) Support enableAsyncState and switch operator after datastream transformation Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-36489) Remove deprecated method `StreamTableEnvironment#toRetractStream` Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-36363) Remove references to scala-relate api in tests among table modules 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-38392) StreamPandasConversionTests failing 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-36132) Remove codes that references TableSource and TableSink directly at the API level. Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-32742) Remove flink-examples-batch module 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-34033) flink json supports raw type Yuepeng Pan (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-35166) Improve the performance of Hybrid Shuffle when enable memory decoupling Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-36882) Introduce MiniBatchGroupAggFunction in GroupAggregate with Async State API Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-33202) FLIP-327: Support switching from batch to stream mode to improve throughput when processing backlog data Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-32641) json format supports pojo type Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34156) Move Flink Calcite rules from Scala to Java Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34004) TestingCheckpointIDCounter can easily lead to NPEs Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-33674) In the wmassigners module, words are misspelled Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-32607) Kafka table source and json format support projection pushdown 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-34338) An exception is thrown when some named params change order when using window tvf Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-32753) Print JVM flags on AZP Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-33631) Remove HA ConfigMap label setup Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34315) Temporarily force disabling window join, window rank and window deduplicate optimization when using session window tvf Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34397) Resource wait timeout can't be disabled Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-32641) json format supports pojo type 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-32871) Support BuiltInMethod TO_TIMESTAMP with timezone options Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-33085) Improve the error message when the invalidate lookupTableSource without primary key is used as temporal join table Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-33558) Externalize Elasticsearch Python connector code Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34431) Move static BlobWriter methods to separate util Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34033) flink json supports raw type Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34189) FLIP-416: Deprecate and remove the RestoreMode#LEGACY Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-33626) Wrong style in flink ui Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-33584) Update Hadoop Filesystems to 3.3.6 Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-33626) Wrong style in flink ui Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-33528) Externalize Python connector code 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-34264) Prometheuspushgateway's hosturl can use basicAuth certification login Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34129) MiniBatchGlobalGroupAggFunction will make -D as +I then make +I as -U when state expired Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-32745) Add a flag to skip InputSelectable preValidate step Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34241) Transfer external connectors's CI result to Flink Slack #builds channel Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34241) Transfer external connectors's CI result to Flink Slack #builds channel Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-28726) CompileException: BoundedOverAggregateHelper must implement method AggsHandeFunction.setWindowSize(int) Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-32873) Add configuration to allow disabling SQL query hints Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-32873) Add configuration to allow disabling SQL query hints Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34134) Add tracing for restored state size and locations Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34064) FLIP-417: Expose JobManagerOperatorMetrics via REST API Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34191) Remove RestoreMode#LEGACY Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-32871) Support BuiltInMethod TO_TIMESTAMP with timezone options Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-33950) Update max aggregate functions to new type system Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-32742) Remove flink-examples-batch module Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34338) An exception is thrown when some named params change order when using window tvf Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-32607) Kafka table source and json format support projection pushdown 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-33674) In the wmassigners module, words are misspelled Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-33558) Externalize Elasticsearch Python connector code Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-33584) Update Hadoop Filesystems to 3.3.6 Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34315) Temporarily force disabling window join, window rank and window deduplicate optimization when using session window tvf Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34134) Add tracing for restored state size and locations Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34156) Move Flink Calcite rules from Scala to Java Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-33557) Externalize Cassandra Python connector code Yuepeng Pan (Jira)