From ce5353281ef67822a3ae653534d781a91d7b96eb Mon Sep 17 00:00:00 2001 From: tobe Date: Thu, 27 Jan 2022 15:00:06 +0800 Subject: [PATCH] Fix git plugin and return version of openmldb-batch --- java/openmldb-batch/pom.xml | 16 ++++++++++++++++ .../openmldb/batch/api/OpenmldbSession.scala | 8 +++----- 2 files changed, 19 insertions(+), 5 deletions(-) diff --git a/java/openmldb-batch/pom.xml b/java/openmldb-batch/pom.xml index 505ad8fb3aa..fc0bf597872 100644 --- a/java/openmldb-batch/pom.xml +++ b/java/openmldb-batch/pom.xml @@ -438,6 +438,22 @@ pl.project13.maven git-commit-id-plugin + 2.2.4 + + + get-the-git-infos + + revision + + + + + ${project.build.outputDirectory}/openmldb_git.properties + true + yyyy.MM.dd HH:mm:ss + true + true + diff --git a/java/openmldb-batch/src/main/scala/com/_4paradigm/openmldb/batch/api/OpenmldbSession.scala b/java/openmldb-batch/src/main/scala/com/_4paradigm/openmldb/batch/api/OpenmldbSession.scala index a355d19ae81..aafd63afe59 100755 --- a/java/openmldb-batch/src/main/scala/com/_4paradigm/openmldb/batch/api/OpenmldbSession.scala +++ b/java/openmldb-batch/src/main/scala/com/_4paradigm/openmldb/batch/api/OpenmldbSession.scala @@ -18,9 +18,8 @@ package com._4paradigm.openmldb.batch.api import com._4paradigm.openmldb.batch.catalog.OpenmldbCatalogService import com._4paradigm.openmldb.batch.{OpenmldbBatchConfig, SparkPlanner} -import com._4paradigm.openmldb.sdk.impl.SqlClusterExecutor import org.apache.commons.io.IOUtils -import org.apache.spark.SparkConf +import org.apache.spark.{SPARK_VERSION, SparkConf} import org.apache.spark.sql.catalyst.QueryPlanningTracker import org.apache.spark.sql.catalyst.plans.logical.LogicalPlan import org.apache.spark.sql.{DataFrame, Dataset, Row, SparkSession} @@ -196,10 +195,9 @@ class OpenmldbSession { val stream = this.getClass.getClassLoader.getResourceAsStream("openmldb_git.properties") if (stream == null) { logger.error("OpenMLDB git properties is missing") - s"${sparkSession.version}" + SPARK_VERSION } else { - val gitInfo = IOUtils.toString(stream, "UTF-8") - s"${sparkSession.version}\n$gitInfo" + s"$SPARK_VERSION\n${IOUtils.toString(stream, "UTF-8")}" } }