[kv] fix ci

Author: beryllw

fluss-client/src/test/java/org/apache/fluss/client/table/FlussTableITCase.java

@@ -296,7 +296,7 @@ void testPutAutoIncColumnAndLookup() throws Exception {
                 Schema.newBuilder()
                         .column("col1", DataTypes.STRING())
                         .withComment("col1 is first column")
-                        .column("b", DataTypes.BIGINT())
+                        .column("col2", DataTypes.BIGINT())
                         .withComment("col2 is second column, auto increment column")
                         .setAutoIncrement(true)
                         .primaryKey("col1")

fluss-common/src/main/java/org/apache/fluss/utils/json/ColumnJsonSerde.java

@@ -37,6 +37,7 @@ public class ColumnJsonSerde
     static final String ID = "id";
     static final String DATA_TYPE = "data_type";
     static final String COMMENT = "comment";
+    static final String AUTO_INC = "auto_inc";
 
     @Override
     public void serialize(Schema.Column column, JsonGenerator generator) throws IOException {
@@ -50,6 +51,10 @@ public void serialize(Schema.Column column, JsonGenerator generator) throws IOEx
             generator.writeStringField(COMMENT, column.getComment().get());
         }
         generator.writeNumberField(ID, column.getColumnId());
+        if (column.isAutoInc()) {
+            generator.writeFieldName(AUTO_INC);
+            generator.writeBoolean(column.isAutoInc());
+        }
 
         generator.writeEndObject();
     }
@@ -64,6 +69,7 @@ public Schema.Column deserialize(JsonNode node) {
                 columnName,
                 dataType,
                 node.hasNonNull(COMMENT) ? node.get(COMMENT).asText() : null,
-                node.has(ID) ? node.get(ID).asInt() : UNKNOWN_COLUMN_ID);
+                node.has(ID) ? node.get(ID).asInt() : UNKNOWN_COLUMN_ID,
+                node.hasNonNull(AUTO_INC) && node.get(AUTO_INC).asBoolean());
     }
 }