diff --git a/flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/writer/GSCommitRecoverableSerializer.java b/flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/writer/GSCommitRecoverableSerializer.java
index b92c49fdadfd2..58f112012f5dc 100644
--- a/flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/writer/GSCommitRecoverableSerializer.java
+++ b/flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/writer/GSCommitRecoverableSerializer.java
@@ -40,7 +40,7 @@ class GSCommitRecoverableSerializer implements SimpleVersionedSerializer<GSCommi
             LoggerFactory.getLogger(GSCommitRecoverableSerializer.class);
 
     /** Current version of serializer. */
-    private static final int SERIALIZER_VERSION = 0;
+    private static final int SERIALIZER_VERSION = 1;
 
     /** The one and only instance of the serializer. */
     public static final GSCommitRecoverableSerializer INSTANCE =
@@ -133,7 +133,7 @@ static GSCommitRecoverable deserializeCommitRecoverable(DataInputStream dataInpu
 
     @Override
     public GSCommitRecoverable deserialize(int version, byte[] serialized) throws IOException {
-        Preconditions.checkArgument(version >= 0);
+        Preconditions.checkArgument(version > 0);
         Preconditions.checkNotNull(serialized);
 
         // ensure this serializer can deserialize data with this version
diff --git a/flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/writer/GSResumeRecoverableSerializer.java b/flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/writer/GSResumeRecoverableSerializer.java
index d3120c4c6d8a2..3341aa4a112e3 100644
--- a/flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/writer/GSResumeRecoverableSerializer.java
+++ b/flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/writer/GSResumeRecoverableSerializer.java
@@ -37,7 +37,7 @@ class GSResumeRecoverableSerializer implements SimpleVersionedSerializer<GSResum
             LoggerFactory.getLogger(GSResumeRecoverableSerializer.class);
 
     /** Current version of serializer. */
-    private static final int SERIALIZER_VERSION = 0;
+    private static final int SERIALIZER_VERSION = 1;
 
     /** The one and only instance of the serializer. */
     public static final GSResumeRecoverableSerializer INSTANCE =
@@ -83,7 +83,7 @@ public byte[] serialize(GSResumeRecoverable recoverable) throws IOException {
 
     @Override
     public GSResumeRecoverable deserialize(int version, byte[] serialized) throws IOException {
-        Preconditions.checkArgument(version >= 0);
+        Preconditions.checkArgument(version > 0);
         Preconditions.checkNotNull(serialized);
 
         // ensure this serializer can deserialize data with this version