(flink) branch master updated: [hotfix][runtime] Fix getOrinalTypeSerializerSnapshot typo (#29046)

[panyuepeng]

This is an automated email from the ASF dual-hosted git repository.

RocMarshal pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 76e774e04ff [hotfix][runtime] Fix getOrinalTypeSerializerSnapshot typo 
(#29046)
76e774e04ff is described below

commit 76e774e04ff84ea305714153c5f4790fff98437c
Author: Weiqing Yang <yangweiqing...@gmail.com>
AuthorDate: Sun Aug 30 07:14:19 2026 -0700

    [hotfix][runtime] Fix getOrinalTypeSerializerSnapshot typo (#29046)
    
    Rename TtlAwareSerializerSnapshot#getOrinalTypeSerializerSnapshot to
    getOriginalTypeSerializerSnapshot, matching the correctly spelled
    TtlAwareSerializer#getOriginalTypeSerializer that it mirrors.
    
    Generated-by: Claude Code (Opus 5)
---
 .../runtime/state/ttl/TtlAwareSerializerSnapshot.java      | 14 +++++++-------
 .../flink/runtime/state/ttl/TtlAwareSerializerTest.java    |  2 +-
 2 files changed, 8 insertions(+), 8 deletions(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlAwareSerializerSnapshot.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlAwareSerializerSnapshot.java
index f3092988e39..73b1b11285d 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlAwareSerializerSnapshot.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlAwareSerializerSnapshot.java
@@ -110,22 +110,22 @@ public class TtlAwareSerializerSnapshot<T> implements 
TypeSerializerSnapshot<T>
             // Check compatibility from disabling to enabling ttl
             TtlStateFactory.TtlSerializerSnapshot<T> newSerializerSnapshot =
                     (TtlStateFactory.TtlSerializerSnapshot<T>)
-                            this.getOrinalTypeSerializerSnapshot();
+                            this.getOriginalTypeSerializerSnapshot();
             TypeSerializerSchemaCompatibility<T> compatibility =
                     newSerializerSnapshot
                             .getValueSerializerSnapshot()
                             .resolveSchemaCompatibility(
                                     oldTtlAwareSerializerSnapshot
-                                            
.getOrinalTypeSerializerSnapshot());
+                                            
.getOriginalTypeSerializerSnapshot());
 
             return resolveCompatibilityForTtlMigration(compatibility);
         } else if (oldTtlAwareSerializerSnapshot.isTtlEnabled() && 
!this.isTtlEnabled()) {
             // Check compatibility from enabling to disabling ttl
             TtlStateFactory.TtlSerializerSnapshot<T> oldTtlSerializerSnapshot =
                     (TtlStateFactory.TtlSerializerSnapshot<T>)
-                            
oldTtlAwareSerializerSnapshot.getOrinalTypeSerializerSnapshot();
+                            
oldTtlAwareSerializerSnapshot.getOriginalTypeSerializerSnapshot();
             TypeSerializerSchemaCompatibility<T> compatibility =
-                    this.getOrinalTypeSerializerSnapshot()
+                    this.getOriginalTypeSerializerSnapshot()
                             .resolveSchemaCompatibility(
                                     
oldTtlSerializerSnapshot.getValueSerializerSnapshot());
 
@@ -133,16 +133,16 @@ public class TtlAwareSerializerSnapshot<T> implements 
TypeSerializerSnapshot<T>
         }
 
         // Check compatibility with the same ttl config
-        return this.getOrinalTypeSerializerSnapshot()
+        return this.getOriginalTypeSerializerSnapshot()
                 .resolveSchemaCompatibility(
-                        
oldTtlAwareSerializerSnapshot.getOrinalTypeSerializerSnapshot());
+                        
oldTtlAwareSerializerSnapshot.getOriginalTypeSerializerSnapshot());
     }
 
     public boolean isTtlEnabled() {
         return isTtlEnabled;
     }
 
-    public TypeSerializerSnapshot<T> getOrinalTypeSerializerSnapshot() {
+    public TypeSerializerSnapshot<T> getOriginalTypeSerializerSnapshot() {
         return typeSerializerSnapshot;
     }
 
diff --git 
a/flink-runtime/src/test/java/org/apache/flink/runtime/state/ttl/TtlAwareSerializerTest.java
 
b/flink-runtime/src/test/java/org/apache/flink/runtime/state/ttl/TtlAwareSerializerTest.java
index 90c7f70432c..f91e71d360c 100644
--- 
a/flink-runtime/src/test/java/org/apache/flink/runtime/state/ttl/TtlAwareSerializerTest.java
+++ 
b/flink-runtime/src/test/java/org/apache/flink/runtime/state/ttl/TtlAwareSerializerTest.java
@@ -130,7 +130,7 @@ class TtlAwareSerializerTest {
         assertThat(
                         ((TtlAwareSerializerSnapshot<?>)
                                         
intTtlAwareSerializer.snapshotConfiguration())
-                                .getOrinalTypeSerializerSnapshot())
+                                .getOriginalTypeSerializerSnapshot())
                 .isInstanceOf(IntSerializer.IntSerializerSnapshot.class);
 
         assertThat(listTtlAwareSerializer.snapshotConfiguration())