diff --git a/hive-metastore/src/main/java/org/apache/iceberg/hive/HiveTableOperations.java b/hive-metastore/src/main/java/org/apache/iceberg/hive/HiveTableOperations.java index d54d4de63..b442ea0ef 100644 --- a/hive-metastore/src/main/java/org/apache/iceberg/hive/HiveTableOperations.java +++ b/hive-metastore/src/main/java/org/apache/iceberg/hive/HiveTableOperations.java @@ -600,7 +600,9 @@ protected long acquireLock() throws UnknownHostException, TException, Interrupte .run( id -> { try { + LOG.warn("In thread {}, trying to call hmsclient.checkLock() on table {}", Thread.currentThread(), fullName); LockResponse response = metaClients.run(client -> client.checkLock(id)); + LOG.warn("In thread {}, hmsclient.checkLock() finished on table {}", Thread.currentThread(), fullName); LockState newState = response.getState(); state.set(newState); if (newState.equals(LockState.WAITING)) {