You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@vxquery.apache.org by vi...@apache.org on 2012/07/04 02:55:25 UTC
svn commit: r1357028 - in /incubator/vxquery/branches/vxquery_algebricks:
vxquery-cli/src/main/java/org/apache/vxquery/cli/VXQuery.java
vxquery-xtest/src/main/java/org/apache/vxquery/xtest/TestRunnerFactory.java
Author: vinayakb
Date: Wed Jul 4 00:55:24 2012
New Revision: 1357028
URL: http://svn.apache.org/viewvc?rev=1357028&view=rev
Log:
Modified code to work with Hyracks client API changes
Modified:
incubator/vxquery/branches/vxquery_algebricks/vxquery-cli/src/main/java/org/apache/vxquery/cli/VXQuery.java
incubator/vxquery/branches/vxquery_algebricks/vxquery-xtest/src/main/java/org/apache/vxquery/xtest/TestRunnerFactory.java
Modified: incubator/vxquery/branches/vxquery_algebricks/vxquery-cli/src/main/java/org/apache/vxquery/cli/VXQuery.java
URL: http://svn.apache.org/viewvc/incubator/vxquery/branches/vxquery_algebricks/vxquery-cli/src/main/java/org/apache/vxquery/cli/VXQuery.java?rev=1357028&r1=1357027&r2=1357028&view=diff
==============================================================================
--- incubator/vxquery/branches/vxquery_algebricks/vxquery-cli/src/main/java/org/apache/vxquery/cli/VXQuery.java (original)
+++ incubator/vxquery/branches/vxquery_algebricks/vxquery-cli/src/main/java/org/apache/vxquery/cli/VXQuery.java Wed Jul 4 00:55:24 2012
@@ -161,8 +161,7 @@ public class VXQuery {
}
private void runInProcess(JobSpecification spec, File result) throws Exception {
- JobId jobId = hcc.createJob("test", spec, EnumSet.of(JobFlag.PROFILE_RUNTIME));
- hcc.start(jobId);
+ JobId jobId = hcc.startJob("test", spec, EnumSet.of(JobFlag.PROFILE_RUNTIME));
hcc.waitForCompletion(jobId);
dumpOutputFiles(result);
}
Modified: incubator/vxquery/branches/vxquery_algebricks/vxquery-xtest/src/main/java/org/apache/vxquery/xtest/TestRunnerFactory.java
URL: http://svn.apache.org/viewvc/incubator/vxquery/branches/vxquery_algebricks/vxquery-xtest/src/main/java/org/apache/vxquery/xtest/TestRunnerFactory.java?rev=1357028&r1=1357027&r2=1357028&view=diff
==============================================================================
--- incubator/vxquery/branches/vxquery_algebricks/vxquery-xtest/src/main/java/org/apache/vxquery/xtest/TestRunnerFactory.java (original)
+++ incubator/vxquery/branches/vxquery_algebricks/vxquery-xtest/src/main/java/org/apache/vxquery/xtest/TestRunnerFactory.java Wed Jul 4 00:55:24 2012
@@ -113,8 +113,7 @@ public class TestRunnerFactory {
compiler.compile(testCase.getXQueryDisplayName(), in, ccb, opts.optimizationLevel);
JobSpecification spec = compiler.getModule().getHyracksJobSpecification();
spec.setMaxReattempts(0);
- JobId jobId = hcc.createJob("test", spec, EnumSet.of(JobFlag.PROFILE_RUNTIME));
- hcc.start(jobId);
+ JobId jobId = hcc.startJob("test", spec, EnumSet.of(JobFlag.PROFILE_RUNTIME));
hcc.waitForCompletion(jobId);
res.result = FileUtils.readFileToString(tempFile, "UTF-8").trim();
} catch (Throwable e) {