From 9636cb2ccd172ae7fb98ab772a1817504966c749 Mon Sep 17 00:00:00 2001 From: Kent Yao Date: Sat, 17 Oct 2020 00:05:51 +0800 Subject: [PATCH] KyuubiHadoopUtilsSuite --- .../kyuubi/util/KyuubiHadoopUtils.scala | 1 - .../kyuubi/util/KyuubiHadoopUtilsSuite.scala | 38 +++++++++++++++++++ 2 files changed, 38 insertions(+), 1 deletion(-) create mode 100644 kyuubi-common/src/test/scala/org/apache/kyuubi/util/KyuubiHadoopUtilsSuite.scala diff --git a/kyuubi-common/src/main/scala/org/apache/kyuubi/util/KyuubiHadoopUtils.scala b/kyuubi-common/src/main/scala/org/apache/kyuubi/util/KyuubiHadoopUtils.scala index 27fe10bf8..98afd30d1 100644 --- a/kyuubi-common/src/main/scala/org/apache/kyuubi/util/KyuubiHadoopUtils.scala +++ b/kyuubi-common/src/main/scala/org/apache/kyuubi/util/KyuubiHadoopUtils.scala @@ -30,5 +30,4 @@ object KyuubiHadoopUtils { } hadoopConf } - } diff --git a/kyuubi-common/src/test/scala/org/apache/kyuubi/util/KyuubiHadoopUtilsSuite.scala b/kyuubi-common/src/test/scala/org/apache/kyuubi/util/KyuubiHadoopUtilsSuite.scala new file mode 100644 index 000000000..9eedfdff4 --- /dev/null +++ b/kyuubi-common/src/test/scala/org/apache/kyuubi/util/KyuubiHadoopUtilsSuite.scala @@ -0,0 +1,38 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.kyuubi.util + +import org.apache.kyuubi.KyuubiFunSuite +import org.apache.kyuubi.config.KyuubiConf + +class KyuubiHadoopUtilsSuite extends KyuubiFunSuite { + + test("new hadoop conf with kyuubi conf") { + val abc = "kyuubi.hadoop.abc" + val xyz = "kyuubi.hadoop.xyz" + val test = "hadoop.test" + val kyuubiConf = new KyuubiConf() + .set(abc, "xyz") + .set(xyz, "abc") + .set(test, "t") + val hadoopConf = KyuubiHadoopUtils.newHadoopConf(kyuubiConf) + assert(hadoopConf.get(abc.stripPrefix("kyuubi.")) === "xyz") + assert(hadoopConf.get(xyz.stripPrefix("kyuubi.")) === "abc") + assert(hadoopConf.get("hadoop.test") === null) + } +}