Code rollback

cas-bigdatalab · Nov 3, 2022 · f24cb33 · f24cb33
1 parent 8c8e336
commit f24cb33
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 2 deletions.
diff --git a/piflow-core/src/main/scala/cn/piflow/main.scala b/piflow-core/src/main/scala/cn/piflow/main.scala
@@ -802,9 +802,12 @@ class ProcessImpl(flow: Flow, runnerContext: Context, runner: Runner, parentProc
             outputs.saveData(debugPath)
           }
 
+          /*
           //monitor the throughput
-          if(null != PropertyUtil.getPropertyValue("monitor.throughput") && PropertyUtil.getPropertyValue("monitor.throughput").toBoolean == true)
+          if(null != PropertyUtil.getPropertyValue("monitor.throughput") && PropertyUtil.getPropertyValue("monitor.throughput").toBoolean == true) {
             runnerListener.monitorJobCompleted(pe.getContext(), outputs : JobOutputStream)
+          }
+          */
 
           runnerListener.onJobCompleted(pe.getContext());
 

diff --git a/piflow-server/src/main/scala/cn/piflow/api/API.scala b/piflow-server/src/main/scala/cn/piflow/api/API.scala
@@ -512,13 +512,14 @@ object API {
     """{"stopWithGroup":"""" + resultList.mkString(",") + """"}"""
   }
 
-    
+  /*
   def  getThroughput(appId:String, stopName:String, portName:String):String = {
     //test   
     //H2Util.addThroughput("a","b","c",100)
     H2Util.getThroughput(appId, stopName, portName)
     // "out 200"
   }
+  */
 
   private def getLogFile(uuid : String, appName : String) : (File,File) = {
     val now : Date = new Date()

diff --git a/piflow-server/src/main/scala/cn/piflow/api/HTTPService.scala b/piflow-server/src/main/scala/cn/piflow/api/HTTPService.scala
@@ -699,6 +699,7 @@ object HTTPService extends DefaultJsonProtocol with Directives with SprayJsonSup
      }
 
    }
+   /*
    case HttpRequest(GET, Uri.Path("/monitor/throughout"), headers, entity, protocol) => {
 
      val appId = req.getUri().query().getOrElse("appId", "")
@@ -714,6 +715,7 @@ object HTTPService extends DefaultJsonProtocol with Directives with SprayJsonSup
        }
      }
    }
+   */
 
    case HttpRequest(GET, Uri.Path("/visualDataDirectory/data"), headers, entity, protocol) =>{
      try{
-Original file line number
+Diff line change
@@ Expand Up @@
          }
        }
+       /*
        case HttpRequest(GET, Uri.Path("/monitor/throughout"), headers, entity, protocol) => {
          val appId = req.getUri().query().getOrElse("appId", "")
@@ Expand All @@
            }
          }
        }
+       */
        case HttpRequest(GET, Uri.Path("/visualDataDirectory/data"), headers, entity, protocol) =>{
          try{
@@ Expand Down @@