fix meta field compatibility in partition info table

Signed-off-by: chenxu <[email protected]>
lakesoul-io · Oct 8, 2023 · f315b45 · f315b45
1 parent df5aa7e
commit f315b45
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/lakesoul-common/src/main/java/com/dmetasoul/lakesoul/meta/dao/PartitionInfoDao.java b/lakesoul-common/src/main/java/com/dmetasoul/lakesoul/meta/dao/PartitionInfoDao.java
@@ -605,7 +605,8 @@ public static PartitionInfo partitionInfoFromResultSet(ResultSet rs) throws SQLE
                 .setTimestamp(rs.getLong("timestamp"));
         Array snapshotArray = rs.getArray("snapshot");
         partitionInfo.addAllSnapshot(Arrays.stream((UUID[]) snapshotArray.getArray()).map(DBUtil::toProtoUuid).collect(Collectors.toList()));
-        partitionInfo.setExpression(rs.getString("expression"));
+        String expr = rs.getString("expression");
+        partitionInfo.setExpression(expr == null ? "" : expr);
         return partitionInfo.build();
     }
 
@@ -617,7 +618,8 @@ public static PartitionInfo partitionInfoFromResultSetWithoutTimestamp(ResultSet
                 .setCommitOp(CommitOp.valueOf(rs.getString("commit_op")));
         Array snapshotArray = rs.getArray("snapshot");
         partitionInfo.addAllSnapshot(Arrays.stream((UUID[]) snapshotArray.getArray()).map(DBUtil::toProtoUuid).collect(Collectors.toList()));
-        partitionInfo.setExpression(rs.getString("expression"));
+        String expr = rs.getString("expression");
+        partitionInfo.setExpression(expr == null ? "" : expr);
         return partitionInfo.build();
     }
 }