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");