bug fixes

uwescience · Dec 16, 2016 · 7dfebf0 · 7dfebf0
1 parent 1d52041
commit 7dfebf0
Show file tree

Hide file tree

Showing 6 changed files with 10 additions and 10 deletions.
diff --git a/perfenforce_files/filesToFetch.txt b/perfenforce_files/filesToFetch.txt
@@ -10,7 +10,7 @@ PSLAGeneration/weka.jar
 PSLAGeneration/tiers.txt
 PSLAGeneration/training.arff
 PerfEnforceScaling/moa.jar
-PerfEnforceScaling/training.jar
+PerfEnforceScaling/training.arff
 PerfEnforceScaling/features/4
 PerfEnforceScaling/features/6
 PerfEnforceScaling/features/8

diff --git a/src/edu/washington/escience/myria/api/PerfEnforceResource.java b/src/edu/washington/escience/myria/api/PerfEnforceResource.java
@@ -41,8 +41,8 @@ public Response prepareData(final List<PerfEnforceTableEncoding> tableList)
 
   @GET
   @Path("/getDataPreparationStatus")
-  public String getDataPreparationStatus() {
-    return server.getPerfEnforceDriver().getDataPreparationStatus();
+  public Response getDataPreparationStatus() {
+    return Response.ok(server.getPerfEnforceDriver().getDataPreparationStatus()).build();
   }
 
   @GET

diff --git a/src/edu/washington/escience/myria/api/encoding/PerfEnforceQueryMetadataEncoding.java b/src/edu/washington/escience/myria/api/encoding/PerfEnforceQueryMetadataEncoding.java
@@ -18,6 +18,7 @@ public PerfEnforceQueryMetadataEncoding(
 
     this.id = id;
     this.slaRuntime = slaRuntime;
+    this.queryText = queryText;
   }
 
   public double getSLA() {

diff --git a/src/edu/washington/escience/myria/perfenforce/PSLAManagerWrapper.java b/src/edu/washington/escience/myria/perfenforce/PSLAManagerWrapper.java
@@ -31,7 +31,7 @@ public void generateQueries() throws Exception {
                   "mono "
                       + PSLAManagerExePath.toString()
                       + " -f "
-                      + PerfEnforceDriver.configurationPath.toString()
+                      + PerfEnforceDriver.configurationPath.resolve("PSLAGeneration").toString()
                       + " -q");
 
       System.out.println(IOUtils.toString(p.getErrorStream()));
@@ -50,7 +50,7 @@ public void generatePSLA() throws Exception {
                   "mono "
                       + PSLAManagerExePath.toString()
                       + " -f "
-                      + PerfEnforceDriver.configurationPath.toString()
+                      + PerfEnforceDriver.configurationPath.resolve("PSLAGeneration").toString()
                       + " -p");
 
       p.waitFor();

diff --git a/src/edu/washington/escience/myria/perfenforce/PerfEnforceDriver.java b/src/edu/washington/escience/myria/perfenforce/PerfEnforceDriver.java
@@ -79,6 +79,7 @@ public void fetchS3Files() throws PerfEnforceException, Exception {
   }
 
   public void preparePSLA(List<PerfEnforceTableEncoding> tableList) throws Exception {
+    isDonePSLA = false;
     PerfEnforceDriver.tableList = tableList;
     fetchS3Files();
 
@@ -114,8 +115,9 @@ public void preparePSLA(List<PerfEnforceTableEncoding> tableList) throws Excepti
     PSLAManagerWrapper pslaManager = new PSLAManagerWrapper();
     pslaManager.generateQueries();
     perfenforceDataPrepare.collectFeaturesFromGeneratedQueries();
-
     pslaManager.generatePSLA();
+
+    dataPreparationStatus = "Finished";
     isDonePSLA = true;
   }
 

diff --git a/src/edu/washington/escience/myria/perfenforce/PerfEnforceOnlineLearning.java b/src/edu/washington/escience/myria/perfenforce/PerfEnforceOnlineLearning.java
@@ -138,13 +138,10 @@ public void findBestClusterSize() throws PerfEnforceException {
             PerfEnforceUtils.getMaxFeature(
                 server, currentQueryForConfiguration, currentClusterSize);
 
-        String maxFeatureForConfiguration =
-            PerfEnforceUtils.getMaxFeature(server, currentQueryFeatures, c);
-
         FileWriter featureWriterForConfiguration;
         featureWriterForConfiguration =
             new FileWriter(Paths.get(onlineLearningPath, "features", String.valueOf(c)).toString());
-        featureWriterForConfiguration.write(maxFeatureForConfiguration + '\n');
+        featureWriterForConfiguration.write(currentQueryFeatures + '\n');
         featureWriterForConfiguration.close();
       }
     } catch (Exception e) {