>From Michael Blow <[email protected]>:
Michael Blow has submitted this change. (
https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/18521 )
Change subject: Merge branch 'gerrit/neo' into 'gerrit/trinity'
......................................................................
Merge branch 'gerrit/neo' into 'gerrit/trinity'
Change-Id: I5d88dc0e5b3303751fe5fc33eb5c1df99949f5c9
---
M
hyracks-fullstack/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/job/JobRun.java
M
hyracks-fullstack/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/job/JobManager.java
M
asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/utils/RequestTracker.java
4 files changed, 13 insertions(+), 22 deletions(-)
Approvals:
Jenkins: Verified; Verified
Michael Blow: Looks good to me, approved
diff --git
a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/utils/RequestTracker.java
b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/utils/RequestTracker.java
index af39793..ef9154d 100644
---
a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/utils/RequestTracker.java
+++
b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/utils/RequestTracker.java
@@ -138,7 +138,6 @@
}
@Override
-<<<<<<< HEAD (85d2b0 [NO ISSUE][HYR][MISC] += invocation helpers for
unchecked ex)
public void incrementFailedRequests() {
numOfFailedRequests.incrementAndGet();
}
@@ -149,8 +148,6 @@
}
@Override
-=======
->>>>>>> BRANCH (5b3465 [ASTERIXDB-3343][API] Add servlet to get
acitve/completed re)
public void notifyJobCreation(JobId jobId, JobSpecification spec,
IJobCapacityController.JobSubmissionStatus status)
throws HyracksException {
String requestId = spec.getRequestId();
diff --git
a/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/job/JobManager.java
b/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/job/JobManager.java
index 3c8135a..be3daae 100644
---
a/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/job/JobManager.java
+++
b/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/job/JobManager.java
@@ -121,7 +121,6 @@
public void add(JobRun jobRun) throws HyracksException {
checkJob(jobRun);
JobSpecification job = jobRun.getJobSpecification();
-<<<<<<< HEAD (85d2b0 [NO ISSUE][HYR][MISC] += invocation helpers for
unchecked ex)
IJobCapacityController.JobSubmissionStatus status;
try {
status = jobCapacityController.allocate(job);
@@ -140,20 +139,6 @@
} catch (HyracksDataException ex) {
handleException(ex);
throw ex;
-=======
- IJobCapacityController.JobSubmissionStatus status =
jobCapacityController.allocate(job);
- CCServiceContext serviceCtx = ccs.getContext();
- serviceCtx.notifyJobCreation(jobRun.getJobId(), job, status);
- switch (status) {
- case QUEUE:
- queueJob(jobRun);
- break;
- case EXECUTE:
- executeJob(jobRun);
- break;
- default:
- throw new IllegalStateException("unknown submission status: "
+ status);
->>>>>>> BRANCH (5b3465 [ASTERIXDB-3343][API] Add servlet to get
acitve/completed re)
}
}
diff --git
a/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/job/JobRun.java
b/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/job/JobRun.java
index 196282f..da4d12d 100644
---
a/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/job/JobRun.java
+++
b/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/job/JobRun.java
@@ -226,10 +226,6 @@
return startTime > 0 ? startTime - createTime :
System.currentTimeMillis() - createTime;
}
- public long getQueueWaitTimeInMillis() {
- return startTime > 0 ? startTime - createTime :
System.currentTimeMillis() - createTime;
- }
-
public void registerOperatorLocation(OperatorDescriptorId op, int
partition, String location) {
operatorLocations.computeIfAbsent(op, k -> new
HashMap<>()).put(partition, location);
}
--
To view, visit https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/18521
To unsubscribe, or for help writing mail filters, visit
https://asterix-gerrit.ics.uci.edu/settings
Gerrit-Project: asterixdb
Gerrit-Branch: trinity
Gerrit-Change-Id: I5d88dc0e5b3303751fe5fc33eb5c1df99949f5c9
Gerrit-Change-Number: 18521
Gerrit-PatchSet: 2
Gerrit-Owner: Michael Blow <[email protected]>
Gerrit-Reviewer: Jenkins <[email protected]>
Gerrit-Reviewer: Michael Blow <[email protected]>
Gerrit-MessageType: merged
