Use table name as cache key explicitly

Make it more obvious that the cache key for `snapshotIds` is correct.
trinodb · Aug 3, 2021 · dd113a3 · dd113a3
1 parent 722c9fa
commit dd113a3
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergMetadata.java b/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergMetadata.java
@@ -1021,7 +1021,8 @@ public TableStatistics getTableStatistics(ConnectorSession session, ConnectorTab
 
     private Optional<Long> getSnapshotId(org.apache.iceberg.Table table, Optional<Long> snapshotId)
     {
-        return snapshotIds.computeIfAbsent(table.toString(), ignored -> snapshotId
+        // table.name() is an encoded version of SchemaTableName
+        return snapshotIds.computeIfAbsent(table.name(), ignored -> snapshotId
                 .map(id -> IcebergUtil.resolveSnapshotId(table, id))
                 .or(() -> Optional.ofNullable(table.currentSnapshot()).map(Snapshot::snapshotId)));
     }