@Test
public void canExecuteFromPhysicalPlan() {

  doAnswer(invocation -> {
    ResponseListener<QueryResponse> listener = invocation.getArgument(1);
    listener.onResponse(new QueryResponse(schema, Collections.emptyList()));
    return null;
  }).when(executionEngine).execute(any(), any());
  sqlService.execute(mock(PhysicalPlan.class),
      new ResponseListener<QueryResponse>() {
        @Override
        public void onResponse(QueryResponse response) {
          assertNotNull(response);
        }
        @Override
        public void onFailure(Exception e) {
          fail(e);
        }
      });
}