Skip to content

Commit

Permalink
fix ut
Browse files Browse the repository at this point in the history
  • Loading branch information
morningman committed Jun 3, 2022
1 parent 2dd009d commit a98a82e
Showing 1 changed file with 9 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -344,6 +344,15 @@ public void execPlanFragment(InternalService.PExecPlanFragmentRequest request,
responseObserver.onCompleted();
}

@Override
public void execPlanFragmentPrepare(InternalService.PExecPlanFragmentRequest request,
StreamObserver<InternalService.PExecPlanFragmentResult> responseObserver) {
System.out.println("get exec_plan_fragment_prepare request");
responseObserver.onNext(InternalService.PExecPlanFragmentResult.newBuilder()
.setStatus(Types.PStatus.newBuilder().setStatusCode(0)).build());
responseObserver.onCompleted();
}

@Override
public void execPlanFragmentStart(InternalService.PExecPlanFragmentStartRequest request,
StreamObserver<InternalService.PExecPlanFragmentResult> responseObserver) {
Expand Down

0 comments on commit a98a82e

Please sign in to comment.