From f186d035834dc2767884afef775e7266f650958f Mon Sep 17 00:00:00 2001 From: Raymond Zhang Date: Mon, 2 Dec 2024 15:34:06 -0800 Subject: [PATCH] add logging --- .../main/java/org/apache/iceberg/hive/HiveTableOperations.java | 2 ++ 1 file changed, 2 insertions(+) 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)) {