diff --git a/piflow-core/src/main/scala/cn/piflow/util/H2Util.scala b/piflow-core/src/main/scala/cn/piflow/util/H2Util.scala index 7733221..2ff7c2c 100644 --- a/piflow-core/src/main/scala/cn/piflow/util/H2Util.scala +++ b/piflow-core/src/main/scala/cn/piflow/util/H2Util.scala @@ -63,6 +63,7 @@ object H2Util { val startedStopList = getStartedStop(appId) startedStopList.foreach(stopName => { updateStopState(appId,stopName,StopState.KILLED) + updateStopFinishedTime(appId, stopName, new Date().toString) }) } //println(updateSql) diff --git a/piflow-server/src/main/scala/cn/piflow/api/API.scala b/piflow-server/src/main/scala/cn/piflow/api/API.scala index e811d71..498d4ee 100644 --- a/piflow-server/src/main/scala/cn/piflow/api/API.scala +++ b/piflow-server/src/main/scala/cn/piflow/api/API.scala @@ -155,6 +155,7 @@ object API { //update db H2Util.updateFlowState(appID, FlowState.KILLED) + H2Util.updateFlowFinishedTime(appID, new Date().toString) "ok" }