diff --git spark-client/src/main/java/org/apache/hive/spark/client/JobHandle.java spark-client/src/main/java/org/apache/hive/spark/client/JobHandle.java index fd5daf4..152899d 100644 --- spark-client/src/main/java/org/apache/hive/spark/client/JobHandle.java +++ spark-client/src/main/java/org/apache/hive/spark/client/JobHandle.java @@ -54,6 +54,4 @@ */ SparkCounters getSparkCounters(); - // TODO: expose job status? - } diff --git spark-client/src/main/java/org/apache/hive/spark/client/JobHandleImpl.java spark-client/src/main/java/org/apache/hive/spark/client/JobHandleImpl.java index 6aeb6b7..7b289cf 100644 --- spark-client/src/main/java/org/apache/hive/spark/client/JobHandleImpl.java +++ spark-client/src/main/java/org/apache/hive/spark/client/JobHandleImpl.java @@ -118,8 +118,6 @@ public void setSparkCounters(SparkCounters sparkCounters) { this.sparkCounters = sparkCounters; } - // TODO: expose job status? - @SuppressWarnings("unchecked") void setSuccess(Object result) { promise.setSuccess((T) result); diff --git spark-client/src/main/java/org/apache/hive/spark/client/RemoteDriver.java spark-client/src/main/java/org/apache/hive/spark/client/RemoteDriver.java index c873e8a..5aa883f 100644 --- spark-client/src/main/java/org/apache/hive/spark/client/RemoteDriver.java +++ spark-client/src/main/java/org/apache/hive/spark/client/RemoteDriver.java @@ -371,7 +371,6 @@ private void monitorJob(JavaFutureAction job, @Override public void onJobStart(SparkListenerJobStart jobStart) { - // TODO: are stage IDs unique? Otherwise this won't work. synchronized (stageToJobId) { for (int i = 0; i < jobStart.stageIds().length(); i++) { stageToJobId.put((Integer) jobStart.stageIds().apply(i), jobStart.jobId());