@@ -123,15 +123,15 @@ public ObPayload invokeSync(final ObTableConnection conn, final ObPayload reques
123
123
boolean isNeedRefreshMeta = false ;
124
124
ObRpcResultCode resultCode = new ObRpcResultCode ();
125
125
resultCode .decode (buf );
126
- logger .warn ( "[routing feedback] require_rerouting_: {}, need_refresh_kv_meta_: {}"
126
+ logger .debug ( " require_rerouting_: {}, need_refresh_kv_meta_: {}"
127
127
, response .getHeader ().isRoutingWrong (), response .getHeader ().isNeedRefreshKvMeta ());
128
128
if (response .getHeader ().getPcode () != Pcodes .OB_TABLE_API_MOVE ) {
129
129
if (resultCode .getRcode () != 0 ) {
130
130
String errMessage = TraceUtil .formatTraceMessage (conn , request ,
131
131
"meet exception: [error code:" + resultCode .getRcode () + "]"
132
132
+ resultCode .getErrMsg ());
133
- logger .warn (errMessage );
134
- if (needFetchMeta (resultCode .getRcode (), resultCode . getPcode () )) {
133
+ logger .debug (errMessage );
134
+ if (needFetchMeta (resultCode .getRcode ())) {
135
135
throw new ObTableNeedFetchMetaException (errMessage , resultCode .getRcode ());
136
136
} else if (needFetchPartitionLocation (resultCode .getRcode ())) {
137
137
throw new ObTableRoutingWrongException (errMessage , resultCode .getRcode ());
@@ -191,7 +191,7 @@ protected InvokeFuture createInvokeFuture(Connection conn, RemotingCommand reque
191
191
}
192
192
193
193
// schema changed
194
- private boolean needFetchMeta (int errorCode , int pcode ) {
194
+ private boolean needFetchMeta (int errorCode ) {
195
195
return errorCode == ResultCodes .OB_SCHEMA_ERROR .errorCode
196
196
|| errorCode == ResultCodes .OB_TABLE_NOT_EXIST .errorCode
197
197
|| errorCode == ResultCodes .OB_TABLET_NOT_EXIST .errorCode
0 commit comments