Skip to content

Commit

Permalink
update log
Browse files Browse the repository at this point in the history
  • Loading branch information
rzhang10 committed Dec 2, 2024
1 parent f186d03 commit 50f6745
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -195,7 +195,7 @@ protected void doCommit(TableMetadata base, TableMetadata metadata) {
ReentrantLock tableLevelMutex = commitLockCache.get(fullName, t -> new ReentrantLock(true));
tableLevelMutex.lock();
try {
LOG.warn("In thread {}, starting to create a lock for table {}", Thread.currentThread(), fullName);
LOG.warn("In thread {}, starting to acquire a lock for table {}", Thread.currentThread(), fullName);
lockId = Optional.of(acquireLock());
LOG.warn("In thread {}, acquired lock id: {} for table {}", Thread.currentThread(), lockId.get(), fullName);
// TODO add lock heart beating for cases where default lock timeout is too low.
Expand All @@ -209,9 +209,9 @@ protected void doCommit(TableMetadata base, TableMetadata metadata) {
boolean tableExists = metaClients.run(client -> client.tableExists(database, tableName));
LOG.warn("In thread {}, checking table exists finishes with result: {}", Thread.currentThread(), tableExists);
if (tableExists) {
LOG.warn("In thread {}, starting to get table {} from HMS", Thread.currentThread(), fullName);
LOG.warn("In thread {}, starting to call getTable: {} from HMS", Thread.currentThread(), fullName);
tbl = metaClients.run(client -> client.getTable(database, tableName));
LOG.warn("In thread {}, got table {} from HMS", Thread.currentThread(), fullName);
LOG.warn("In thread {}, getTable: {} from HMS finished", Thread.currentThread(), fullName);
fixMismatchedSchema(tbl);
} else {
final long currentTimeMillis = System.currentTimeMillis();
Expand Down

0 comments on commit 50f6745

Please sign in to comment.