diff --git service/src/test/org/apache/hive/service/cli/CLIServiceTest.java service/src/test/org/apache/hive/service/cli/CLIServiceTest.java index 237fcc0..f325dbc 100644 --- service/src/test/org/apache/hive/service/cli/CLIServiceTest.java +++ service/src/test/org/apache/hive/service/cli/CLIServiceTest.java @@ -665,8 +665,8 @@ public void testTaskStatus() throws Exception { ByteArrayInputStream in = new ByteArrayInputStream(jsonTaskStatus.getBytes("UTF-8")); List taskStatuses = mapper.readValue(in, new TypeReference>(){}); - checkTaskStatuses(taskStatuses); System.out.println("task statuses: " + jsonTaskStatus); // TaskDisplay doesn't have a toString, using json + checkTaskStatuses(taskStatuses); if (OperationState.CANCELED == state || state == OperationState.CLOSED || state == OperationState.FINISHED || state == OperationState.ERROR) { @@ -693,9 +693,6 @@ private void checkTaskStatuses(List taskDisplays) { assertNull(taskDisplay.getReturnValue()); break; case RUNNING: - if (taskDisplay.getTaskType() == StageType.MAPRED || taskDisplay.getTaskType() == StageType.MAPREDLOCAL) { - assertNotNull(taskDisplay.getExternalHandle()); - } assertNotNull(taskDisplay.getBeginTime()); assertNull(taskDisplay.getEndTime()); assertNotNull(taskDisplay.getElapsedTime());