tikv
/
client-java
mirror of https://github.com/tikv/client-java.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix pd response is null (#10)

This commit is contained in:
birdstorm 2018-12-08 19:08:26 +08:00 committed by GitHub
parent eeced35f2c
commit a93e507126
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/org/tikv/operation/PDErrorHandler.java
View File

@ -18,6 +18,7 @@
package org.tikv.operation; package org.tikv.operation;
import java.util.function.Function; import java.util.function.Function;
import org.apache.log4j.Logger;
import org.tikv.PDClient; import org.tikv.PDClient;
import org.tikv.exception.GrpcException; import org.tikv.exception.GrpcException;
import org.tikv.kvproto.Pdpb; import org.tikv.kvproto.Pdpb;
@ -25,6 +26,7 @@ import org.tikv.util.BackOffFunction;
import org.tikv.util.BackOffer; import org.tikv.util.BackOffer;
public class PDErrorHandler<RespT> implements ErrorHandler<RespT> { public class PDErrorHandler<RespT> implements ErrorHandler<RespT> {
private static final Logger logger = Logger.getLogger(PDErrorHandler.class);
private final Function<RespT, Pdpb.Error> getError; private final Function<RespT, Pdpb.Error> getError;
private final PDClient client; private final PDClient client;
@ -36,7 +38,9 @@ public class PDErrorHandler<RespT> implements ErrorHandler<RespT> {
@Override @Override
public boolean handleResponseError(BackOffer backOffer, RespT resp) { public boolean handleResponseError(BackOffer backOffer, RespT resp) {
if (resp == null) { if (resp == null) {
return false; String msg = "Request Failed with unknown reason for PD GetRegionResponse";
logger.warn(msg);
return handleRequestError(backOffer, new GrpcException(msg));
} }
Pdpb.Error error = getError.apply(resp); Pdpb.Error error = getError.apply(resp);
if (error != null) { if (error != null) {