This is an automated email from the ASF dual-hosted git repository.
casion pushed a commit to branch dev-1.3.1
in repository https://gitbox.apache.org/repos/asf/incubator-linkis.git
The following commit(s) were added to refs/heads/dev-1.3.1 by this push:
new 0570eb967 feat: linkis-storage unit test add
new a7a3b8f48 Merge pull request #3790 from
ruY9527/dev-1.3.1-linkis-storage-unit-test
0570eb967 is described below
commit 0570eb967813fb0bfdf8336364f7df9f8b9329d4
Author: ruY9527 <[email protected]>
AuthorDate: Sat Nov 5 19:00:12 2022 +0800
feat: linkis-storage unit test add
---
.../LinkisIoFileClientErrorCodeSummaryTest.java | 43 +++++++++++
.../LinkisIoFileErrorCodeSummaryTest.java | 40 +++++++++++
.../LinkisStorageErrorCodeSummaryTest.java | 66 +++++++++++++++++
.../storage/exception/StorageErrorCodeTest.java | 33 +++++++++
.../storage/conf/LinkisStorageConfTest.scala | 47 ++++++++++++
.../linkis/storage/domain/DataTypeTest.scala | 63 ++++++++++++++++
.../linkis/storage/script/VariableParserTest.scala | 53 ++++++++++++++
.../storage/utils/StorageConfigurationTest.scala | 84 ++++++++++++++++++++++
8 files changed, 429 insertions(+)
diff --git
a/linkis-commons/linkis-storage/src/test/java/org/apache/linkis/storage/errorcode/LinkisIoFileClientErrorCodeSummaryTest.java
b/linkis-commons/linkis-storage/src/test/java/org/apache/linkis/storage/errorcode/LinkisIoFileClientErrorCodeSummaryTest.java
new file mode 100644
index 000000000..19a54802c
--- /dev/null
+++
b/linkis-commons/linkis-storage/src/test/java/org/apache/linkis/storage/errorcode/LinkisIoFileClientErrorCodeSummaryTest.java
@@ -0,0 +1,43 @@
+/*
+ * 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.linkis.storage.errorcode;
+
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.DisplayName;
+import org.junit.jupiter.api.Test;
+
+public class LinkisIoFileClientErrorCodeSummaryTest {
+
+ @Test
+ @DisplayName("enumTest")
+ public void enumTest() {
+
+ int noProxyUserErrorCode =
LinkisIoFileClientErrorCodeSummary.NO_PROXY_USER.getErrorCode();
+ int failedToInitUserErrorCode =
+ LinkisIoFileClientErrorCodeSummary.FAILED_TO_INIT_USER.getErrorCode();
+ int engineClosedIoIllegalErrorCode =
+
LinkisIoFileClientErrorCodeSummary.ENGINE_CLOSED_IO_ILLEGAL.getErrorCode();
+ int storageHasBeenClosedErrorCode =
+
LinkisIoFileClientErrorCodeSummary.STORAGE_HAS_BEEN_CLOSED.getErrorCode();
+
+ Assertions.assertTrue(52002 == noProxyUserErrorCode);
+ Assertions.assertTrue(52002 == failedToInitUserErrorCode);
+ Assertions.assertTrue(52002 == engineClosedIoIllegalErrorCode);
+ Assertions.assertTrue(52002 == storageHasBeenClosedErrorCode);
+ }
+}
diff --git
a/linkis-commons/linkis-storage/src/test/java/org/apache/linkis/storage/errorcode/LinkisIoFileErrorCodeSummaryTest.java
b/linkis-commons/linkis-storage/src/test/java/org/apache/linkis/storage/errorcode/LinkisIoFileErrorCodeSummaryTest.java
new file mode 100644
index 000000000..c57ccd2e5
--- /dev/null
+++
b/linkis-commons/linkis-storage/src/test/java/org/apache/linkis/storage/errorcode/LinkisIoFileErrorCodeSummaryTest.java
@@ -0,0 +1,40 @@
+/*
+ * 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.linkis.storage.errorcode;
+
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.DisplayName;
+import org.junit.jupiter.api.Test;
+
+public class LinkisIoFileErrorCodeSummaryTest {
+
+ @Test
+ @DisplayName("enumTest")
+ public void enumTest() {
+
+ int cannotBeEmptyErrorCode =
LinkisIoFileErrorCodeSummary.CANNOT_BE_EMPTY.getErrorCode();
+ int fsCanNotProxyToErrorCode =
LinkisIoFileErrorCodeSummary.FS_CAN_NOT_PROXY_TO.getErrorCode();
+ int notExistsMethodErrorCode =
LinkisIoFileErrorCodeSummary.NOT_EXISTS_METHOD.getErrorCode();
+ int parameterCallsErrorCode =
LinkisIoFileErrorCodeSummary.PARAMETER_CALLS.getErrorCode();
+
+ Assertions.assertTrue(53002 == cannotBeEmptyErrorCode);
+ Assertions.assertTrue(52002 == fsCanNotProxyToErrorCode);
+ Assertions.assertTrue(53003 == notExistsMethodErrorCode);
+ Assertions.assertTrue(53003 == parameterCallsErrorCode);
+ }
+}
diff --git
a/linkis-commons/linkis-storage/src/test/java/org/apache/linkis/storage/errorcode/LinkisStorageErrorCodeSummaryTest.java
b/linkis-commons/linkis-storage/src/test/java/org/apache/linkis/storage/errorcode/LinkisStorageErrorCodeSummaryTest.java
new file mode 100644
index 000000000..935e0f8c7
--- /dev/null
+++
b/linkis-commons/linkis-storage/src/test/java/org/apache/linkis/storage/errorcode/LinkisStorageErrorCodeSummaryTest.java
@@ -0,0 +1,66 @@
+/*
+ * 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.linkis.storage.errorcode;
+
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.DisplayName;
+import org.junit.jupiter.api.Test;
+
+public class LinkisStorageErrorCodeSummaryTest {
+
+ @Test
+ @DisplayName("enumTest")
+ public void enumTest() {
+
+ int unsupportedFileErrorCode =
LinkisStorageErrorCodeSummary.UNSUPPORTED_FILE.getErrorCode();
+ int unsupportedResultErrorCode =
+ LinkisStorageErrorCodeSummary.UNSUPPORTED_RESULT.getErrorCode();
+ int configurationNotReadErrorCode =
+ LinkisStorageErrorCodeSummary.CONFIGURATION_NOT_READ.getErrorCode();
+ int failedToReadIntegerErrorCode =
+ LinkisStorageErrorCodeSummary.FAILED_TO_READ_INTEGER.getErrorCode();
+ int theFileIsEmptyErrorCode =
LinkisStorageErrorCodeSummary.THE_FILE_IS_EMPTY.getErrorCode();
+ int toBeUnknowErrorCode =
LinkisStorageErrorCodeSummary.TO_BE_UNKNOW.getErrorCode();
+ int fsnNotInitExceptionErrorCode =
+ LinkisStorageErrorCodeSummary.FSN_NOT_INIT_EXCEPTION.getErrorCode();
+ int parsingMetadataFailedErrorCode =
+ LinkisStorageErrorCodeSummary.PARSING_METADATA_FAILED.getErrorCode();
+ int tableAreNotSupportedErrorCode =
+ LinkisStorageErrorCodeSummary.TABLE_ARE_NOT_SUPPORTED.getErrorCode();
+ int mustRegisterTocErrorCode =
LinkisStorageErrorCodeSummary.MUST_REGISTER_TOC.getErrorCode();
+ int mustRegisterTomErrorCode =
LinkisStorageErrorCodeSummary.MUST_REGISTER_TOM.getErrorCode();
+ int unsupportedOpenFileTypeErrorCode =
+
LinkisStorageErrorCodeSummary.UNSUPPORTED_OPEN_FILE_TYPE.getErrorCode();
+ int incalidCustomParameterErrorCode =
+ LinkisStorageErrorCodeSummary.INCALID_CUSTOM_PARAMETER.getErrorCode();
+
+ Assertions.assertTrue(50000 == unsupportedFileErrorCode);
+ Assertions.assertTrue(50000 == unsupportedResultErrorCode);
+ Assertions.assertTrue(50001 == configurationNotReadErrorCode);
+ Assertions.assertTrue(51000 == failedToReadIntegerErrorCode);
+ Assertions.assertTrue(51000 == theFileIsEmptyErrorCode);
+ Assertions.assertTrue(51001 == toBeUnknowErrorCode);
+ Assertions.assertTrue(52000 == fsnNotInitExceptionErrorCode);
+ Assertions.assertTrue(52001 == parsingMetadataFailedErrorCode);
+ Assertions.assertTrue(52002 == tableAreNotSupportedErrorCode);
+ Assertions.assertTrue(52004 == mustRegisterTocErrorCode);
+ Assertions.assertTrue(52004 == mustRegisterTomErrorCode);
+ Assertions.assertTrue(54001 == unsupportedOpenFileTypeErrorCode);
+ Assertions.assertTrue(65000 == incalidCustomParameterErrorCode);
+ }
+}
diff --git
a/linkis-commons/linkis-storage/src/test/java/org/apache/linkis/storage/exception/StorageErrorCodeTest.java
b/linkis-commons/linkis-storage/src/test/java/org/apache/linkis/storage/exception/StorageErrorCodeTest.java
new file mode 100644
index 000000000..d020e5bb0
--- /dev/null
+++
b/linkis-commons/linkis-storage/src/test/java/org/apache/linkis/storage/exception/StorageErrorCodeTest.java
@@ -0,0 +1,33 @@
+/*
+ * 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.linkis.storage.exception;
+
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.DisplayName;
+import org.junit.jupiter.api.Test;
+
+public class StorageErrorCodeTest {
+
+ @Test
+ @DisplayName("enumTest")
+ public void enumTest() {
+
+ int fsNotInitCode = StorageErrorCode.FS_NOT_INIT.getCode();
+ Assertions.assertTrue(53001 == fsNotInitCode);
+ }
+}
diff --git
a/linkis-commons/linkis-storage/src/test/scala/org/apache/linkis/storage/conf/LinkisStorageConfTest.scala
b/linkis-commons/linkis-storage/src/test/scala/org/apache/linkis/storage/conf/LinkisStorageConfTest.scala
new file mode 100644
index 000000000..18be0620b
--- /dev/null
+++
b/linkis-commons/linkis-storage/src/test/scala/org/apache/linkis/storage/conf/LinkisStorageConfTest.scala
@@ -0,0 +1,47 @@
+/*
+ * 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.linkis.storage.conf
+
+import org.junit.jupiter.api.{Assertions, DisplayName, Test}
+
+class LinkisStorageConfTest {
+
+ @Test
+ @DisplayName("constTest")
+ def constTest(): Unit = {
+
+ val hdfsfilesystemresterrs = LinkisStorageConf.HDFS_FILE_SYSTEM_REST_ERRS
+ val rowbytemaxlenstr = LinkisStorageConf.ROW_BYTE_MAX_LEN_STR
+ val filetype = LinkisStorageConf.FILE_TYPE
+
+ Assertions.assertNotNull(hdfsfilesystemresterrs)
+ Assertions.assertEquals("2m", rowbytemaxlenstr)
+ Assertions.assertNotNull(filetype)
+
+ }
+
+ @Test
+ @DisplayName("getFileTypeArrTest")
+ def getFileTypeArr(): Unit = {
+
+ val fileTypeArr = LinkisStorageConf.getFileTypeArr
+ Assertions.assertTrue(fileTypeArr.length > 0)
+
+ }
+
+}
diff --git
a/linkis-commons/linkis-storage/src/test/scala/org/apache/linkis/storage/domain/DataTypeTest.scala
b/linkis-commons/linkis-storage/src/test/scala/org/apache/linkis/storage/domain/DataTypeTest.scala
new file mode 100644
index 000000000..3bfc35b17
--- /dev/null
+++
b/linkis-commons/linkis-storage/src/test/scala/org/apache/linkis/storage/domain/DataTypeTest.scala
@@ -0,0 +1,63 @@
+/*
+ * 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.linkis.storage.domain
+
+import org.junit.jupiter.api.{Assertions, DisplayName, Test}
+
+class DataTypeTest {
+
+ @Test
+ @DisplayName("constTest")
+ def constTest(): Unit = {
+
+ val nullvalue = DataType.NULL_VALUE
+ val lowcasenullvalue = DataType.LOWCASE_NULL_VALUE
+
+ Assertions.assertEquals("NULL", nullvalue)
+ Assertions.assertEquals("null", lowcasenullvalue)
+
+ }
+
+ @Test
+ @DisplayName("isNullTest")
+ def isNullTest(): Unit = {
+
+ val bool = DataType.isNull(null)
+ Assertions.assertTrue(bool)
+
+ }
+
+ @Test
+ @DisplayName("isNumberNullTest")
+ def isNumberNullTest(): Unit = {
+
+ val bool = DataType.isNumberNull("123")
+ Assertions.assertFalse(bool)
+
+ }
+
+ @Test
+ @DisplayName("valueToStringTest")
+ def valueToStringTest(): Unit = {
+
+ val str = DataType.valueToString("123")
+ Assertions.assertNotNull(str)
+
+ }
+
+}
diff --git
a/linkis-commons/linkis-storage/src/test/scala/org/apache/linkis/storage/script/VariableParserTest.scala
b/linkis-commons/linkis-storage/src/test/scala/org/apache/linkis/storage/script/VariableParserTest.scala
new file mode 100644
index 000000000..519c7d2af
--- /dev/null
+++
b/linkis-commons/linkis-storage/src/test/scala/org/apache/linkis/storage/script/VariableParserTest.scala
@@ -0,0 +1,53 @@
+/*
+ * 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.linkis.storage.script
+
+import scala.collection.JavaConverters._
+
+import org.junit.jupiter.api.{Assertions, DisplayName, Test}
+
+class VariableParserTest {
+
+ @Test
+ @DisplayName("constTest")
+ def constTest(): Unit = {
+
+ val configuration = VariableParser.CONFIGURATION
+ val variable = VariableParser.VARIABLE
+ val runtime = VariableParser.RUNTIME
+ val startup = VariableParser.STARTUP
+ val special = VariableParser.SPECIAL
+
+ Assertions.assertEquals("configuration", configuration)
+ Assertions.assertEquals("variable", variable)
+ Assertions.assertEquals("runtime", runtime)
+ Assertions.assertEquals("startup", startup)
+ Assertions.assertEquals("special", special)
+
+ }
+
+ @Test
+ @DisplayName("getVariablesTest")
+ def getVariablesTest(): Unit = {
+
+ val map = Map("name" -> new Object())
+ val variables = VariableParser.getVariables(map.asJava)
+ Assertions.assertTrue(variables.length == 0)
+ }
+
+}
diff --git
a/linkis-commons/linkis-storage/src/test/scala/org/apache/linkis/storage/utils/StorageConfigurationTest.scala
b/linkis-commons/linkis-storage/src/test/scala/org/apache/linkis/storage/utils/StorageConfigurationTest.scala
new file mode 100644
index 000000000..31d7e977a
--- /dev/null
+++
b/linkis-commons/linkis-storage/src/test/scala/org/apache/linkis/storage/utils/StorageConfigurationTest.scala
@@ -0,0 +1,84 @@
+/*
+ * 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.linkis.storage.utils
+
+import org.junit.jupiter.api.{Assertions, DisplayName, Test}
+
+class StorageConfigurationTest {
+
+ @Test
+ @DisplayName("constTest")
+ def constTest(): Unit = {
+
+ val storagerootuser = StorageConfiguration.STORAGE_ROOT_USER.getValue
+ val hdfsrootuser = StorageConfiguration.HDFS_ROOT_USER.getValue
+ val localrootuser = StorageConfiguration.LOCAL_ROOT_USER.getValue
+ val storageusergroup = StorageConfiguration.STORAGE_USER_GROUP.getValue
+ val storagersfiletype = StorageConfiguration.STORAGE_RS_FILE_TYPE.getValue
+ val storagersfilesuffix =
StorageConfiguration.STORAGE_RS_FILE_SUFFIX.getValue
+ val types = StorageConfiguration.ResultTypes
+ val storageresultsetpackage =
StorageConfiguration.STORAGE_RESULT_SET_PACKAGE.getValue
+ val storageresultsetclasses =
StorageConfiguration.STORAGE_RESULT_SET_CLASSES.getValue
+ val storagebuildfsclasses =
StorageConfiguration.STORAGE_BUILD_FS_CLASSES.getValue
+ val issharenode = StorageConfiguration.IS_SHARE_NODE.getValue
+ val enableioproxy = StorageConfiguration.ENABLE_IO_PROXY.getValue
+ val ioUser = StorageConfiguration.IO_USER.getValue
+ val iofsexpiretime = StorageConfiguration.IO_FS_EXPIRE_TIME.getValue
+ val iodefaultcreator = StorageConfiguration.IO_DEFAULT_CREATOR.getValue
+ val iofsreinit = StorageConfiguration.IO_FS_RE_INIT.getValue
+ val ioinitretrylimit = StorageConfiguration.IO_INIT_RETRY_LIMIT.getValue
+ val storagehdfsgroup = StorageConfiguration.STORAGE_HDFS_GROUP.getValue
+ val doublefractionlen = StorageConfiguration.DOUBLE_FRACTION_LEN.getValue
+ val hdfspathprefixcheckon =
StorageConfiguration.HDFS_PATH_PREFIX_CHECK_ON.getValue
+ val hdfspathprefixremove =
StorageConfiguration.HDFS_PATH_PREFIX_REMOVE.getValue
+ val fscachedisable = StorageConfiguration.FS_CACHE_DISABLE.getValue
+ val fschecksumdisbale = StorageConfiguration.FS_CHECKSUM_DISBALE.getValue
+
+ Assertions.assertEquals("hadoop", storagerootuser)
+ Assertions.assertEquals("hadoop", hdfsrootuser)
+ Assertions.assertEquals("root", localrootuser)
+ Assertions.assertEquals("bdap", storageusergroup)
+ Assertions.assertEquals("utf-8", storagersfiletype)
+ Assertions.assertEquals(".dolphin", storagersfilesuffix)
+ Assertions.assertTrue(types.size > 0)
+ Assertions.assertEquals("org.apache.linkis.storage.resultset",
storageresultsetpackage)
+ Assertions.assertEquals(
+
"txt.TextResultSet,table.TableResultSet,io.IOResultSet,html.HtmlResultSet,picture.PictureResultSet",
+ storageresultsetclasses
+ )
+ Assertions.assertEquals(
+
"org.apache.linkis.storage.factory.impl.BuildHDFSFileSystem,org.apache.linkis.storage.factory.impl.BuildLocalFileSystem",
+ storagebuildfsclasses
+ )
+ Assertions.assertTrue(issharenode)
+ Assertions.assertFalse(enableioproxy)
+ Assertions.assertEquals("root", ioUser)
+ Assertions.assertTrue(600000 == iofsexpiretime)
+ Assertions.assertEquals("IDE", iodefaultcreator)
+ Assertions.assertEquals("re-init", iofsreinit)
+ Assertions.assertTrue(10 == ioinitretrylimit)
+ Assertions.assertEquals("hadoop", storagehdfsgroup)
+ Assertions.assertTrue(30 == doublefractionlen)
+ Assertions.assertTrue(hdfspathprefixcheckon)
+ Assertions.assertTrue(hdfspathprefixremove)
+ Assertions.assertFalse(fscachedisable)
+ Assertions.assertFalse(fschecksumdisbale)
+
+ }
+
+}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
