@@ -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 ());
0 commit comments