Skip to content

Commit 593f657

Browse files
committed
add debug log
1 parent 859812f commit 593f657

File tree

4 files changed

+8
-0
lines changed

4 files changed

+8
-0
lines changed

src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2095,6 +2095,8 @@ public ObPayload executeWithRetry(ObTable obTable, ObPayload request, String tab
20952095
throw new ObTableRoutingWrongException();
20962096
}
20972097
} else if (result != null && result.isRoutingWrong()) {
2098+
logger.debug("errors happened in server and retried successfully, server ip:port is {}:{}, tableName: {}, need_refresh_meta: {}",
2099+
obTable.getIp(), obTable.getPort(), tableName, result.isNeedRefreshMeta());
20982100
if (result.isNeedRefreshMeta()) {
20992101
tableRoute.refreshMeta(tableName);
21002102
}

src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/AbstractQueryStreamResult.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -175,6 +175,8 @@ protected ObPayload commonExecute(ObTableClient client, Logger logger,
175175
throw new ObTableRoutingWrongException();
176176
}
177177
} else if (result != null && result.isRoutingWrong()) {
178+
logger.debug("errors happened in server and retried successfully, server ip:port is {}:{}, tableName: {}, need_refresh_meta: {}",
179+
subObTable.getIp(), subObTable.getPort(), indexTableName, result.isNeedRefreshMeta());
178180
TableEntry tableEntry = result.isNeedRefreshMeta() ?
179181
client.getOrRefreshTableEntry(indexTableName, true) :
180182
client.getOrRefreshTableEntry(indexTableName, false);

src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientBatchOpsImpl.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -379,6 +379,8 @@ public void partitionExecute(ObTableOperationResult[] results,
379379
throw new ObTableRoutingWrongException();
380380
}
381381
} else if (result != null && result.isRoutingWrong()) {
382+
logger.debug("errors happened in server and retried successfully, server ip:port is {}:{}, tableName: {}, need_refresh_meta: {}",
383+
subObTable.getIp(), subObTable.getPort(), tableName, result.isNeedRefreshMeta());
382384
TableEntry entry = result.isNeedRefreshMeta() ?
383385
obTableClient.getOrRefreshTableEntry(tableName, true) :
384386
obTableClient.getOrRefreshTableEntry(tableName, false);

src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientLSBatchOpsImpl.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -647,6 +647,8 @@ public void partitionExecute(ObTableSingleOpResult[] results,
647647
}
648648
} else if (result != null && result.isRoutingWrong()) {
649649
// retry successfully in server and need to refresh client cache
650+
logger.debug("errors happened in server and retried successfully, server ip:port is {}:{}, tableName: {}, need_refresh_meta: {}",
651+
subObTable.getIp(), subObTable.getPort(), realTableName, result.isNeedRefreshMeta());
650652
if (result.isNeedRefreshMeta()) {
651653
obTableClient.getOrRefreshTableEntry(realTableName, true);
652654
}

0 commit comments

Comments
 (0)