issues

Messages by Date

2026/10/30 [jira] [Updated] (FLINK-38444) Join calculates upsert keys with null keys for left join 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-35061) Migrate TemporalJoinUtil Yuepeng Pan (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] [Updated] (FLINK-40933) BETWEEN with equal bounds drops trailing spaces of the bound Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-31193) The option `table.exec.hive.native-agg-function.enabled` should work at job level when using it in SqlClient side Yuepeng Pan (Jira)
2026/10/30 [jira] [Commented] (FLINK-41247) AbstractServerTest.testPortRangeSuccess sees an open server connection after the servers are closed Purushottam Sinha (Jira)
2026/10/30 [jira] [Updated] (FLINK-30285) Inline checkstyle config into pom Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-32537) Add compatibility annotation for REST API classes 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] [Commented] (FLINK-39422) [FLINK][OpenAPI] OpenApiSpecGenerator produces incorrect schemas for types with custom Jackson serializers Nikhil S (Jira)
2026/10/30 [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/10/30 [jira] [Updated] (FLINK-37477) Emit full deletes from StreamJoin if it gets deletes on key on input 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-29967) Optimize determinism requirements from sink node with considering that SinkUpsertMaterializer already supports upsertKey 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-34431) Move static BlobWriter methods to separate util Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-32070) FLIP-306 Unified File Merging Mechanism for Checkpoints Yuepeng Pan (Jira)
2026/10/30 Re: [PR] [FLINK-40452] Cap exception fetching by size instead of line count [flink-kubernetes-operator] via GitHub
2026/10/30 Re: [PR] [FLINK-30644][tests] Fix flaky ChangelogCompatibilityITCase [flink] via GitHub
2026/10/30 [jira] [Assigned] (FLINK-40630) Use Apache Parent POM 39 in flink-connector-parent Martijn Visser (Jira)
2026/10/30 Re: [PR] [FLINK-30644][tests] Fix flaky ChangelogCompatibilityITCase [flink] via GitHub
2026/10/30 [jira] [Updated] (FLINK-33557) Externalize Cassandra Python connector code Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-33893) Implement restore tests for PythonCorrelate node Yuepeng Pan (Jira)
2026/10/30 [jira] [Commented] (FLINK-41247) AbstractServerTest.testPortRangeSuccess sees an open server connection after the servers are closed Martijn Visser (Jira)
2026/10/30 [jira] [Updated] (FLINK-41247) AbstractServerTest.testPortRangeSuccess sees an open server connection after the servers are closed Martijn Visser (Jira)
2026/10/30 [jira] [Updated] (FLINK-11868) [filesystems] Introduce listStatusIterator API to file system Yuepeng Pan (Jira)
2026/10/30 Re: [PR] [FLINK-41247][queryable-state] Close server channels before shutting down the Netty event loops [flink] via GitHub
2026/10/30 Re: [PR] [FLINK-41247][queryable-state] Close server channels before shutting down the Netty event loops [flink] via GitHub
2026/10/30 [jira] [Updated] (FLINK-28893) Add conv function supported in SQL & Table API 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-19007) Automatically set presto staging directory to io.tmp.dirs Yuepeng Pan (Jira)
2026/10/30 Re: [PR] [BP-2.2][FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink] via GitHub
2026/10/30 [jira] [Updated] (FLINK-25322) Support no-claim mode in changelog state backend Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-26764) Support RESPECT NULLS for FIRST_VALUE/LAST_VALUE Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-33120) FLIP-361: Improve GC Metrics 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-20687) Missing 'yarn-application' target in CLI help message Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-24192) Sql get plan failed. All the inputs have relevant nodes, however the cost is still infinite 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 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-25283) End-to-end application modules create oversized jars Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-35145) Add timeout for cluster termination Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-16143) Turn on more date time functions of blink planner Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-28813) new stach builtinfunction validateClassForRuntime it not correct Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-26003) Use Jackson serialization for persisting TaskExecutor state to working directory Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34608) Migrate BatchPhysicalValuesRule 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-28893) Add conv function supported in SQL & Table API 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-41280) CAST of a TIMESTAMP before 1970 to DATE, TIME or a lower precision returns a wrong value Ramin Gharib (Jira)
2026/10/30 [jira] [Updated] (FLINK-34606) Migrate BatchPhysicalExpandRule Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-19659) Array type supports equals and not_equals operator when element types are different but castable Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-35061) Migrate TemporalJoinUtil Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-24849) Only return stacktrace if RestHandlerException has a cause Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-25419) Support the metadata column to generate dynamic index Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-25862) Refactor SharedStateRegistry to not limit StreamStateHandle to register/unregister 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-28732) Deprecate ambiguous StateTTLConfig#cleanFullSnapshot API Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-24226) Improve error message when trying Presto S3 FS with recoverable writer Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-28422) Fall back to lastest supported HiveShim when user use a higher hive version Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-21637) Wrong results when filtering by timestamp type Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-28074) show statistics details for DESCRIBE EXTENDED 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-27849) Harden correctness for non-deterministic updates present in the changelog pipeline Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-36851) Introduce TemporalProcessTimeJoinOperator in TemporalJoin with Async State API Yuepeng Pan (Jira)
2026/10/30 Re: [PR] [FLINK-41251] Validate the memory configuration when the spec sets memory [flink-kubernetes-operator] via GitHub
2026/10/30 Re: [PR] [FLINK-41192][connector-http] Fail the HTTP sink request when a retry attempt throws [flink-connector-http] via GitHub
2026/10/30 [jira] [Updated] (FLINK-25244) Deprecate Java 8 support Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-19659) Array type supports equals and not_equals operator when element types are different but castable Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-21409) Add Avro to DataTypes & Serialization docs Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-21940) Rowtime/proctime should be obtained from getTimestamp instead of getLong Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-24636) Move cluster deletion operation cache into ResourceManager 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-24636) Move cluster deletion operation cache into ResourceManager 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-39543) Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-23955) submit flink sql job error when flink HA on yarn is configured Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-24048) Move changeLog inference out of optimizing phase Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-25325) Migration Flink from Junit4 to Junit5 Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-31729) Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-24680) Expose UserCodeClassLoader in OperatorCoordinator.Context for registering release hooks Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-40304) Incorrect upsert key inference for PTFs with multiple table arguments Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-33562) Externalize RabbitMQ Python connector code Yuepeng Pan (Jira)
2026/10/30 [jira] [Resolved] (FLINK-41117) Move CI to ubuntu 26 Sergey Nuyanzin (Jira)
2026/10/30 [jira] [Updated] (FLINK-40728) [FLIP-607] Migrate Flink off end-of-life OkHttp; keep it off the core classpath Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-25345) FLIP-196: Source API stability guarantees Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-23869) Correct javadoc of ExecutionConfig#registerKryoType Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-25322) Support no-claim mode in changelog state backend Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-25027) Allow GC of a finished job's JobMaster before the slot timeout is reached Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-16023) jdbc connector's 'connector.table' property should be optional rather than required Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-39991) Drop ReplaceIntersectWithSemiJoinRule Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-24547) A function named row_kind() can get row_kind Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34421) Skip post-compile checks in compile.sh if fast profile is active 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-34421) Skip post-compile checks in compile.sh if fast profile is active 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-27242) Support RENAME PARTITION statement for partitioned table Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-32070) FLIP-306 Unified File Merging Mechanism for Checkpoints 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-36843) Remove deprecated method in flink-table-planner Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-29192) Add completeness test for built-in functions between Java and Python Table API Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34606) Migrate BatchPhysicalExpandRule Yuepeng Pan (Jira)
2026/10/30 Re: [PR] [FLINK-41269][runtime] Do not treat task clean-up failure as fatal [flink] via GitHub
2026/10/30 [jira] [Updated] (FLINK-40997) Regular join picks a random state key among equal-length upsert keys 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-37117) Add docs for async state SQL operators in 2.0 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-24849) Only return stacktrace if RestHandlerException has a cause Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-31267) Fine-Grained Resource Management supports table and sql levels Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-22909) Supports change log inputs for event time operators Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-39340) Transform binary multi join back to regular join Yuepeng Pan (Jira)
2026/10/30 Re: [PR] [BP-2.3][FLINK-40499][runtime] Emit ACTIVE before final MAX_WATERMARK at drain [flink] via GitHub
2026/10/30 [jira] [Updated] (FLINK-37340) Flink supports pushing metrics immediately at the end of the task. Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-22235) Document stability concerns of flamegraphs for heavier jobs Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-29941) Support SQL Client connects to SQL Gateway 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-24536) flink sql where condition is not supported != writing 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-24226) Improve error message when trying Presto S3 FS with recoverable writer Yuepeng Pan (Jira)
2026/10/30 Re: [PR] [BP-2.4][FLINK-40499][runtime] Emit ACTIVE before final MAX_WATERMARK at drain [flink] via GitHub
2026/10/30 [jira] [Updated] (FLINK-31666) Add ARRAY_OVERLAP supported in SQL & Table API Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-30284) Make datadog reporter url configurable Yuepeng Pan (Jira)
2026/10/30 Re: [PR] [FLINK-41251] Validate the memory configuration when the spec sets memory [flink-kubernetes-operator] via GitHub
2026/10/30 [jira] [Updated] (FLINK-19499) Expose Metric Groups to Split Assigners Yuepeng Pan (Jira)
2026/10/30 Re: [PR] [hotfix][python] Fix Java 8 compilation of PythonTypeUtils [flink] via GitHub
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] [Commented] (FLINK-40886) BlobLibraryCacheManagerTest.testApplicationLevelJarSharing fails with FileAlreadyExistsException on the application directory Martijn Visser (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-32738) PROTOBUF format supports projection push down 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-40886) BlobLibraryCacheManagerTest.testApplicationLevelJarSharing fails with FileAlreadyExistsException on the application directory Martijn Visser (Jira)
2026/10/30 Re: [PR] [FLINK-40886][runtime] Do not create the application directory in the final cleanup check [flink] via GitHub
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-30467) Improve the accuracy of estimating the row count of LocalHashAgg to make more two-phase HashAgg operators effective Yuepeng Pan (Jira)
2026/10/30 Re: [PR] [FLINK-41135][jdbc] Don't start a transaction after the end of input [flink-connector-jdbc] via GitHub
2026/10/30 [jira] [Updated] (FLINK-26559) Support Customized Kubernetes Schedulers for Flink Kubernetes Yuepeng Pan (Jira)
2026/10/30 Re: [PR] [FLINK-41060][jdbc] Commit XA transactions in the JdbcSink committer [flink-connector-jdbc] via GitHub
2026/10/30 Re: [PR] [FLINK-41267] Skip state size in cluster info when checkpointing is disabled [flink-kubernetes-operator] via GitHub
2026/10/30 [jira] [Commented] (FLINK-41117) Move CI to ubuntu 26 Sergey Nuyanzin (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 Re: [PR] [BP-1.20][FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink] via GitHub
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-16073) Translate "State & Fault Tolerance" pages into Chinese 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-35970) Update documentation about FLINK-26050 (merging small SST files) Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34609) Migrate BatchPhysicalScriptTransformRule 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-36482) Remove all deprecated methods in `TableEnvironment` Yuepeng Pan (Jira)
2026/10/30 [jira] [Updated] (FLINK-34612) Migrate StreamPhysicalValuesRule Yuepeng Pan (Jira)
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)