[CP][BUGFIX] fix lob remote read
This commit is contained in:
@ -3597,7 +3597,6 @@ int ObLobQueryRemoteReader::do_fetch_rpc_buffer(ObLobAccessParam& param,
|
|||||||
if (handle.has_more()) {
|
if (handle.has_more()) {
|
||||||
if (OB_SUCCESS != (ret = handle.get_more(rpc_buffer))) {
|
if (OB_SUCCESS != (ret = handle.get_more(rpc_buffer))) {
|
||||||
STORAGE_LOG(WARN, "get_more(send request) failed", K(ret));
|
STORAGE_LOG(WARN, "get_more(send request) failed", K(ret));
|
||||||
ret = OB_DATA_SOURCE_TIMEOUT;
|
|
||||||
} else if (rpc_buffer.get_position() < 0) {
|
} else if (rpc_buffer.get_position() < 0) {
|
||||||
ret = OB_ERR_SYS;
|
ret = OB_ERR_SYS;
|
||||||
LOG_ERROR("rpc buffer has no data", K(ret), K(rpc_buffer));
|
LOG_ERROR("rpc buffer has no data", K(ret), K(rpc_buffer));
|
||||||
|
|||||||
Reference in New Issue
Block a user