Skip to content

Commit aeea4c4

Browse files
committed
revert log level and operation timeout
1 parent 593f657 commit aeea4c4

File tree

3 files changed

+6
-6
lines changed

3 files changed

+6
-6
lines changed

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -123,15 +123,15 @@ public ObPayload invokeSync(final ObTableConnection conn, final ObPayload reques
123123
boolean isNeedRefreshMeta = false;
124124
ObRpcResultCode resultCode = new ObRpcResultCode();
125125
resultCode.decode(buf);
126-
logger.warn("[routing feedback] require_rerouting_: {}, need_refresh_kv_meta_: {}"
126+
logger.debug("require_rerouting_: {}, need_refresh_kv_meta_: {}"
127127
, response.getHeader().isRoutingWrong(), response.getHeader().isNeedRefreshKvMeta());
128128
if (response.getHeader().getPcode() != Pcodes.OB_TABLE_API_MOVE) {
129129
if (resultCode.getRcode() != 0) {
130130
String errMessage = TraceUtil.formatTraceMessage(conn, request,
131131
"meet exception: [error code:" + resultCode.getRcode() + "]"
132132
+ resultCode.getErrMsg());
133-
logger.warn(errMessage);
134-
if (needFetchMeta(resultCode.getRcode(), resultCode.getPcode())) {
133+
logger.debug(errMessage);
134+
if (needFetchMeta(resultCode.getRcode())) {
135135
throw new ObTableNeedFetchMetaException(errMessage, resultCode.getRcode());
136136
} else if (needFetchPartitionLocation(resultCode.getRcode())) {
137137
throw new ObTableRoutingWrongException(errMessage, resultCode.getRcode());
@@ -191,7 +191,7 @@ protected InvokeFuture createInvokeFuture(Connection conn, RemotingCommand reque
191191
}
192192

193193
// schema changed
194-
private boolean needFetchMeta(int errorCode, int pcode) {
194+
private boolean needFetchMeta(int errorCode) {
195195
return errorCode == ResultCodes.OB_SCHEMA_ERROR.errorCode
196196
|| errorCode == ResultCodes.OB_TABLE_NOT_EXIST.errorCode
197197
|| errorCode == ResultCodes.OB_TABLET_NOT_EXIST.errorCode

src/main/java/com/alipay/oceanbase/rpc/location/model/TableRoute.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -662,7 +662,7 @@ private void validCachedObTableStatus(String tableName, TableEntry tableEntry, l
662662
ReplicaLocation replica = getPartitionLocation(obPartitionLocationInfo, route);
663663
ObServerAddr addr = replica.getAddr();
664664
ObTable obTable = tableRoster.getTable(addr);
665-
if (obTable != null) {
665+
if (obTable != null && !obTable.isValid()) {
666666
obTable.setValid();
667667
}
668668
}

src/main/java/com/alipay/oceanbase/rpc/property/Property.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -119,7 +119,7 @@ public enum Property {
119119

120120
RPC_LOGIN_TRY_TIMES("rpc.login.try.times", 3, "请求RPC登录的尝试次数"),
121121

122-
RPC_OPERATION_TIMEOUT("rpc.operation.timeout", 10000L, "OB内部执行RPC请求的超时时间"),
122+
RPC_OPERATION_TIMEOUT("rpc.operation.timeout", 2000L, "OB内部执行RPC请求的超时时间"),
123123

124124
// [ObTable][CONNECTION_POOL]
125125
SERVER_CONNECTION_POOL_SIZE("server.connection.pool.size", 1, "单个SERVER的连接数"),

0 commit comments

Comments
 (0)