This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch opt_dict_perf
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/opt_dict_perf by this push:
new b87b6e40df f
b87b6e40df is described below
commit b87b6e40df2b170db691d0defb13789fcd7fae26
Author: yiguolei <[email protected]>
AuthorDate: Mon Mar 13 19:08:22 2023 +0800
f
---
fe/fe-core/src/main/java/org/apache/doris/catalog/Table.java | 11 +++++++++--
1 file changed, 9 insertions(+), 2 deletions(-)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/Table.java
b/fe/fe-core/src/main/java/org/apache/doris/catalog/Table.java
index 6a05c58179..a5cd47d07a 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/catalog/Table.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/Table.java
@@ -143,25 +143,32 @@ public abstract class Table extends MetaObject implements
Writable, TableIf {
}
public void readLock() {
+ LOG.info("{} tryhold yyyyyreadlock", getName(), new Exception());
this.rwLock.readLock().lock();
+ LOG.info("{} hold yyyyyreadlock", getName(), new Exception());
}
public boolean tryReadLock(long timeout, TimeUnit unit) {
try {
+ LOG.info("{} tryhold yyyyyreadlock", getName(), new Exception());
boolean res = this.rwLock.readLock().tryLock(timeout, unit);
if (!res && unit.toSeconds(timeout) >= 1) {
LOG.warn("Failed to try table {}'s read lock. timeout {} {}.
Current owner: {}",
name, timeout, unit.name(), rwLock.getOwner());
}
+ if (res) {
+ LOG.info("{} hold yyyyylreadock", getName(), new Exception());
+ }
return res;
} catch (InterruptedException e) {
- LOG.warn("failed to try read lock at table[" + name + "]", e);
+ LOG.warn("failed to try read lock yyyyyat table[" + name + "]", e);
return false;
}
}
public void readUnlock() {
this.rwLock.readLock().unlock();
+ LOG.info("{} yyyyyreadunlock", getName(), new Exception());
}
public void writeLock() {
@@ -194,7 +201,7 @@ public abstract class Table extends MetaObject implements
Writable, TableIf {
}
return res;
} catch (InterruptedException e) {
- LOG.warn("yyyyyfailed to try write lock at table[" + name + "]",
e);
+ LOG.warn("yyyyyfailed to try yyyyywrite lock at table[" + name +
"]", e);
return false;
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
