diff --git a/fe/fe-core/src/main/java/com/starrocks/connector/iceberg/IcebergMetadata.java b/fe/fe-core/src/main/java/com/starrocks/connector/iceberg/IcebergMetadata.java index d5ca2c53d5a8b..bc8f18ec8760f 100644 --- a/fe/fe-core/src/main/java/com/starrocks/connector/iceberg/IcebergMetadata.java +++ b/fe/fe-core/src/main/java/com/starrocks/connector/iceberg/IcebergMetadata.java @@ -432,7 +432,13 @@ public List getPartitions(Table table, List partitionName CloseableIterable rows = task.asDataTask().rows(); for (StructLike row : rows) { // Get the last updated time of the table according to the table schema - long lastUpdated = row.get(7, Long.class); + long lastUpdated = -1; + try { + lastUpdated = row.get(7, Long.class); + } catch (NullPointerException e) { + LOG.error("The table [{}] snapshot [{}] has been expired", + icebergTable.getRemoteDbName(), icebergTable.getRemoteTableName(), e); + } Partition partition = new Partition(lastUpdated); return ImmutableList.of(partition); }