Skip to content

Commit 088b828

Browse files
authored
Fix print log wrong (#275)
* fix print log when route wrong * fix print error code wrong
1 parent 31f3549 commit 088b828

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/main/java/com/alipay/oceanbase/rpc/bolt/transport/ObTableRemoting.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -124,7 +124,7 @@ public ObPayload invokeSync(final ObTableConnection conn, final ObPayload reques
124124
// If response indicates the request is routed to wrong server, we should refresh the routing meta.
125125
if (!conn.getObTable().isEnableRerouting() && response.getHeader().isRoutingWrong()) {
126126
String errMessage = TraceUtil.formatTraceMessage(conn, request,
127-
"routed to the wrong server: [error code:" + resultCode + "]");
127+
"routed to the wrong server: [error code:" + resultCode.getRcode() + "]" + response.getMessage());
128128
logger.debug(errMessage);
129129
if (needFetchAll(resultCode.getRcode(), resultCode.getPcode())) {
130130
throw new ObTableNeedFetchAllException(errMessage, resultCode.getRcode());
@@ -142,7 +142,7 @@ public ObPayload invokeSync(final ObTableConnection conn, final ObPayload reques
142142
if (resultCode.getRcode() != 0
143143
&& response.getHeader().getPcode() != Pcodes.OB_TABLE_API_MOVE) {
144144
String errMessage = TraceUtil.formatTraceMessage(conn, request,
145-
"routed to the wrong server: [error code:" + resultCode + "]");
145+
"routed to the wrong server: [error code:" + resultCode.getRcode() + "]" + response.getMessage());
146146
logger.debug(errMessage);
147147
if (needFetchAll(resultCode.getRcode(), resultCode.getPcode())) {
148148
throw new ObTableNeedFetchAllException(errMessage, resultCode.getRcode());

0 commit comments

Comments
 (0)