From f72d863cd9cbd17ed1ec2b4bdd3b358998f14449 Mon Sep 17 00:00:00 2001 From: wypb Date: Tue, 12 Nov 2024 18:37:53 +0800 Subject: [PATCH] Don't synchronize on stats update in ThriftHiveMetastore --- .../presto/hive/metastore/thrift/ThriftHiveMetastore.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/presto-hive-metastore/src/main/java/com/facebook/presto/hive/metastore/thrift/ThriftHiveMetastore.java b/presto-hive-metastore/src/main/java/com/facebook/presto/hive/metastore/thrift/ThriftHiveMetastore.java index db795ed0fd6b2..c6c4dd604e47f 100644 --- a/presto-hive-metastore/src/main/java/com/facebook/presto/hive/metastore/thrift/ThriftHiveMetastore.java +++ b/presto-hive-metastore/src/main/java/com/facebook/presto/hive/metastore/thrift/ThriftHiveMetastore.java @@ -581,7 +581,7 @@ private Map groupStatisticsByColumn(List update) + public void updateTableStatistics(MetastoreContext metastoreContext, String databaseName, String tableName, Function update) { PartitionStatistics currentStatistics = getTableStatistics(metastoreContext, databaseName, tableName); PartitionStatistics updatedStatistics = update.apply(currentStatistics); @@ -652,7 +652,7 @@ private void deleteTableColumnStatistics(MetastoreContext metastoreContext, Stri } @Override - public synchronized void updatePartitionStatistics(MetastoreContext metastoreContext, String databaseName, String tableName, String partitionName, Function update) + public void updatePartitionStatistics(MetastoreContext metastoreContext, String databaseName, String tableName, String partitionName, Function update) { PartitionStatistics currentStatistics = requireNonNull( getPartitionStatistics(metastoreContext, databaseName, tableName, ImmutableSet.of(partitionName)).get(partitionName), "getPartitionStatistics() returned null");