[KYUUBI #2424] [Improvement] add Flink compile version and Trino client compile version to KyuubiServer Log

### _Why are the changes needed?_

fix #2424

### _How was this patch tested?_
- [x] Add some test cases that check the changes thoroughly including negative and positive cases if possible

- [ ] Add screenshots for manual tests if appropriate

- [ ] [Run test](https://kyuubi.apache.org/docs/latest/develop_tools/testing.html#running-tests) locally before make a pull request

Closes #2425 from jiaoqingbo/2424.

Closes #2424

9949d9a5 [jiaoqingbo] Update UtilsSuite.scala
ac9afb46 [jiaoqingbo] Update package.scala
e415345d [jiaoqingbo] Update kyuubi-common/src/main/scala/org/apache/kyuubi/package.scala
081b061f [jiaoqingbo] Update kyuubi-server/src/main/scala/org/apache/kyuubi/server/KyuubiServer.scala
c1ade020 [jiaoqingbo] Update build/kyuubi-build-info
6af3dd08 [jiaoqingbo] [KYUUBI #2424] [Improvement] add Flink compile version and Trino client compile version

Authored-by: jiaoqingbo <1178404354@qq.com>
Signed-off-by: Cheng Pan <chengpan@apache.org>
This commit is contained in:
jiaoqingbo 2022-04-21 15:22:10 +08:00 committed by Cheng Pan
parent 4ec707b742
commit a09ad0b676
No known key found for this signature in database
GPG Key ID: 8001952629BCC75D
5 changed files with 12 additions and 1 deletions

View File

@ -28,6 +28,8 @@ echo_build_properties() {
echo kyuubi_spark_version="$5"
echo kyuubi_hive_version="$6"
echo kyuubi_hadoop_version="$7"
echo kyuubi_flink_version="$8"
echo kyuubi_trino_version="$9"
echo user="$USER"
echo revision=$(git rev-parse HEAD)
echo branch=$(git rev-parse --abbrev-ref HEAD)

View File

@ -180,6 +180,8 @@
<arg value="${spark.version}"/>
<arg value="${hive.version}"/>
<arg value="${hadoop.version}"/>
<arg value="${flink.version}"/>
<arg value="${trino.client.version}"/>
</exec>
</target>
</configuration>

View File

@ -48,6 +48,8 @@ package object kyuubi {
val spark_version: String = props.getProperty("kyuubi_spark_version", unknown)
val hive_version: String = props.getProperty("kyuubi_hive_version", unknown)
val hadoop_version: String = props.getProperty("kyuubi_hadoop_version", unknown)
val flink_version: String = props.getProperty("kyuubi_flink_version", unknown)
val trino_version: String = props.getProperty("kyuubi_trino_version", unknown)
val branch: String = props.getProperty("branch", unknown)
val revision: String = props.getProperty("revision", unknown)
val user: String = props.getProperty("user", unknown)
@ -61,6 +63,8 @@ package object kyuubi {
val SPARK_COMPILE_VERSION: String = BuildInfo.spark_version
val HIVE_COMPILE_VERSION: String = BuildInfo.hive_version
val HADOOP_COMPILE_VERSION: String = BuildInfo.hadoop_version
val FLINK_COMPILE_VERSION: String = BuildInfo.flink_version
val TRINO_COMPILE_VERSION: String = BuildInfo.trino_version
val BRANCH: String = BuildInfo.branch
val REVISION: String = BuildInfo.revision
val BUILD_USER: String = BuildInfo.user

View File

@ -42,6 +42,8 @@ class UtilsSuite extends KyuubiFunSuite {
assert(props.getProperty("kyuubi_spark_version") === SPARK_COMPILE_VERSION)
assert(props.getProperty("kyuubi_hive_version") === HIVE_COMPILE_VERSION)
assert(props.getProperty("kyuubi_hadoop_version") === HADOOP_COMPILE_VERSION)
assert(props.getProperty("kyuubi_flink_version") === FLINK_COMPILE_VERSION)
assert(props.getProperty("kyuubi_trino_version") === TRINO_COMPILE_VERSION)
assert(props.getProperty("branch") === BRANCH)
assert(props.getProperty("revision") === REVISION)
assert(props.getProperty("user") === BUILD_USER)

View File

@ -122,7 +122,8 @@ object KyuubiServer extends Logging {
info(s"Version: $KYUUBI_VERSION, Revision: $REVISION, Branch: $BRANCH," +
s" Java: $JAVA_COMPILE_VERSION, Scala: $SCALA_COMPILE_VERSION," +
s" Spark: $SPARK_COMPILE_VERSION, Hadoop: $HADOOP_COMPILE_VERSION," +
s" Hive: $HIVE_COMPILE_VERSION")
s" Hive: $HIVE_COMPILE_VERSION, Flink: $FLINK_COMPILE_VERSION," +
s" Trino: $TRINO_COMPILE_VERSION")
info(s"Using Scala ${Properties.versionString}, ${Properties.javaVmName}," +
s" ${Properties.javaVersion}")
SignalRegister.registerLogger(logger)