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/03 06:40:24 UTC
svn commit: r1356572 -
/incubator/vxquery/branches/vxquery_algebricks/vxquery-xtest/src/main/java/org/apache/vxquery/xtest/TestRunnerFactory.java
Author: vinayakb
Date: Tue Jul 3 04:40:24 2012
New Revision: 1356572
URL: http://svn.apache.org/viewvc?rev=1356572&view=rev
Log:
Changed num re-attempts to 0 on failure. Trimmed result before comparing
Modified:
incubator/vxquery/branches/vxquery_algebricks/vxquery-xtest/src/main/java/org/apache/vxquery/xtest/TestRunnerFactory.java
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=1356572&r1=1356571&r2=1356572&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 Tue Jul 3 04:40:24 2012
@@ -33,6 +33,7 @@ import edu.uci.ics.hyracks.api.client.Hy
import edu.uci.ics.hyracks.api.client.IHyracksClientConnection;
import edu.uci.ics.hyracks.api.job.JobFlag;
import edu.uci.ics.hyracks.api.job.JobId;
+import edu.uci.ics.hyracks.api.job.JobSpecification;
import edu.uci.ics.hyracks.control.cc.ClusterControllerService;
import edu.uci.ics.hyracks.control.common.controllers.CCConfig;
import edu.uci.ics.hyracks.control.common.controllers.NCConfig;
@@ -110,11 +111,12 @@ public class TestRunnerFactory {
RootStaticContextImpl.INSTANCE), new FileSplit[] { new FileSplit("nc1",
tempFile.getAbsolutePath()) });
compiler.compile(testCase.getXQueryDisplayName(), in, ccb, opts.optimizationLevel);
- JobId jobId = hcc.createJob("test", compiler.getModule().getHyracksJobSpecification(),
- EnumSet.of(JobFlag.PROFILE_RUNTIME));
+ JobSpecification spec = compiler.getModule().getHyracksJobSpecification();
+ spec.setMaxReattempts(0);
+ JobId jobId = hcc.createJob("test", spec, EnumSet.of(JobFlag.PROFILE_RUNTIME));
hcc.start(jobId);
hcc.waitForCompletion(jobId);
- res.result = FileUtils.readFileToString(tempFile, "UTF-8");
+ res.result = FileUtils.readFileToString(tempFile, "UTF-8").trim();
} catch (Throwable e) {
res.error = e;
} finally {