From 6d4be16c6827188b7b141a00a1b093b34030190f Mon Sep 17 00:00:00 2001 From: minmingzhu Date: Wed, 19 Jul 2023 05:57:32 +0000 Subject: [PATCH] update Signed-off-by: minmingzhu --- mllib-dal/src/main/scala/com/intel/oap/mllib/Utils.scala | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/mllib-dal/src/main/scala/com/intel/oap/mllib/Utils.scala b/mllib-dal/src/main/scala/com/intel/oap/mllib/Utils.scala index 701850c4a..e0e90a35e 100644 --- a/mllib-dal/src/main/scala/com/intel/oap/mllib/Utils.scala +++ b/mllib-dal/src/main/scala/com/intel/oap/mllib/Utils.scala @@ -20,8 +20,10 @@ import org.apache.spark.ml.linalg.Vector import org.apache.spark.rdd.RDD import org.apache.spark.sql.SparkSession import org.apache.spark.{SPARK_VERSION, SparkConf, SparkContext} + import java.net.InetAddress -import java.io.{File, FileWriter, BufferedWriter} +import java.io.{BufferedWriter, File, FileWriter} +import java.nio.file.Paths import java.time.LocalDateTime import java.time.Duration import java.time.format.DateTimeFormatter @@ -85,7 +87,7 @@ object Utils { val algoTimeStampList = timeZoneName.map((x: String) => (x, new Utils.AlgoTimeStamp(x))).toMap val recorderName = Utils.GlobalTimeTable.register(this) val timeFileName = recorderName + "time_breakdown" - val redirect_path = sys.env.getOrElse("SPARKJOB_CONFIG_DIR", "") + val redirect_path = sys.env.getOrElse("SPARKJOB_CONFIG_DIR", Paths.get("").toAbsolutePath) val current_directory = redirect_path + "/" + timeFileName val timerEnabled = isTimerEnabled()