diff --git a/flint-spark-integration/src/main/scala/org/opensearch/flint/app/FlintInstance.scala b/flint-spark-integration/src/main/scala/org/opensearch/flint/app/FlintInstance.scala index baaca4045..488fb21a7 100644 --- a/flint-spark-integration/src/main/scala/org/opensearch/flint/app/FlintInstance.scala +++ b/flint-spark-integration/src/main/scala/org/opensearch/flint/app/FlintInstance.scala @@ -23,7 +23,6 @@ class FlintInstance( val sessionId: String, var state: String, val lastUpdateTime: Long, - // We need jobStartTime to check if HMAC token is expired or not val jobStartTime: Long = 0, val excludedJobIds: Seq[String] = Seq.empty[String], val error: Option[String] = None) {} @@ -79,7 +78,6 @@ object FlintInstance { val sessionId = scalaSource("sessionId").asInstanceOf[String] val lastUpdateTime = scalaSource("lastUpdateTime").asInstanceOf[Long] // Safely extract 'jobStartTime' considering potential null or absence - // Safely extract 'jobStartTime' considering potential null or absence val jobStartTime: Long = scalaSource.get("jobStartTime") match { case Some(value: java.lang.Long) => value.longValue() // Convert java.lang.Long to Scala Long