diff --git a/paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java b/paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java index 5371e584d57ff..fe7f043363c8e 100644 --- a/paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java +++ b/paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java @@ -365,6 +365,10 @@ public List bucketEntries() { @Override public long rowCount() { + if (!tableSchema.primaryKeys().isEmpty() || deletionVectors) { + throw new UnsupportedOperationException( + "Unsupported short path for primary key table and deletion vectors table"); + } return scan.rowCount(); }