Skip to content

Commit c46d9f4

Browse files
committed
fix print log when route wrong
1 parent bd246ea commit c46d9f4

File tree

2 files changed

+8
-5
lines changed

2 files changed

+8
-5
lines changed

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

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -124,8 +124,8 @@ 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: " + response.getMessage());
128-
logger.warn(errMessage);
127+
"routed to the wrong server: [error code:" + resultCode + "]");
128+
logger.debug(errMessage);
129129
if (needFetchAll(resultCode.getRcode(), resultCode.getPcode())) {
130130
throw new ObTableNeedFetchAllException(errMessage, resultCode.getRcode());
131131
} else if (needFetchPartial(resultCode.getRcode())) {
@@ -135,20 +135,21 @@ public ObPayload invokeSync(final ObTableConnection conn, final ObPayload reques
135135
// possibly due to the client error code version being behind the observer's version.
136136
// Attempting a full refresh here
137137
// and delegating to the upper-level call to determine whether to throw the exception to the user based on the retry result.
138-
logger.warn("get unexpected error code: {}", response.getMessage());
138+
logger.warn("get unexpected error code: {}", errMessage);
139139
throw new ObTableNeedFetchAllException(errMessage, resultCode.getRcode());
140140
}
141141
}
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: " + response.getMessage());
146-
logger.warn(errMessage);
145+
"routed to the wrong server: [error code:" + resultCode + "]");
146+
logger.debug(errMessage);
147147
if (needFetchAll(resultCode.getRcode(), resultCode.getPcode())) {
148148
throw new ObTableNeedFetchAllException(errMessage, resultCode.getRcode());
149149
} else if (needFetchPartial(resultCode.getRcode())) {
150150
throw new ObTableRoutingWrongException(errMessage, resultCode.getRcode());
151151
} else {
152+
logger.warn(errMessage);
152153
ExceptionUtil.throwObTableException(conn.getObTable().getIp(), conn
153154
.getObTable().getPort(), response.getHeader().getTraceId1(), response
154155
.getHeader().getTraceId0(), resultCode.getRcode(), resultCode.getErrMsg());

src/main/java/com/alipay/oceanbase/rpc/protocol/payload/ResultCodes.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -259,6 +259,8 @@ public enum ResultCodes {
259259
OB_CACHE_FREE_BLOCK_NOT_ENOUGH(-4273), //
260260
OB_SYNC_WASH_MB_TIMEOUT(-4274), //
261261
OB_NOT_ALLOW_MIGRATE_IN(-4275), //
262+
OB_GTS_NOT_READY(-4283), //
263+
OB_GTI_NOT_READY(-4383), //
262264
OB_IMPORT_NOT_IN_SERVER(-4505), //
263265
OB_CONVERT_ERROR(-4507), //
264266
OB_BYPASS_TIMEOUT(-4510), //

0 commit comments

Comments
 (0)