@Test
public void canCaptureErrorDuringExecutionFromPhysicalPlan() {

  doThrow(new RuntimeException()).when(executionEngine).execute(any(), any());
  sqlService.execute(mock(PhysicalPlan.class),
      new ResponseListener<QueryResponse>() {
        @Override
        public void onResponse(QueryResponse response) {
          fail();
        }
        @Override
        public void onFailure(Exception e) {
          assertNotNull(e);
        }
      });
}