diff --git a/zeppelin-interpreter/src/test/java/org/apache/zeppelin/iotdb/IoTDBInterpreterTest.java b/zeppelin-interpreter/src/test/java/org/apache/zeppelin/iotdb/IoTDBInterpreterTest.java index 352c6d85a5d99..ff9a556c4fe23 100644 --- a/zeppelin-interpreter/src/test/java/org/apache/zeppelin/iotdb/IoTDBInterpreterTest.java +++ b/zeppelin-interpreter/src/test/java/org/apache/zeppelin/iotdb/IoTDBInterpreterTest.java @@ -30,6 +30,10 @@ import org.junit.Test; import java.io.IOException; +import java.util.ArrayList; +import java.util.Arrays; +import java.util.HashSet; +import java.util.List; import java.util.Properties; import static org.apache.zeppelin.iotdb.IoTDBInterpreter.DEFAULT_ENABLE_RPC_COMPRESSION; @@ -324,7 +328,7 @@ public void testShowTimeseries() { + "root.test.wf01.wt01.hardware\tnull\troot.test.wf01\tFLOAT\tGORILLA\tSNAPPY\tnull\tnull"; Assert.assertNotNull(actual); Assert.assertEquals(Code.SUCCESS, actual.code()); - Assert.assertEquals(gt, actual.message().get(0).getData()); + assertEqualsNonStrict(gt, actual.message().get(0).getData()); } @Test @@ -334,7 +338,7 @@ public void testShowDevices() { "devices\tisAligned\n" + "root.test.wf02.wt02\tfalse\n" + "root.test.wf01.wt01\tfalse"; Assert.assertNotNull(actual); Assert.assertEquals(Code.SUCCESS, actual.code()); - Assert.assertEquals(gt, actual.message().get(0).getData()); + assertEqualsNonStrict(gt, actual.message().get(0).getData()); } @Test @@ -348,7 +352,7 @@ public void testShowDevicesWithSg() { Assert.assertNotNull(actual); Assert.assertEquals(Code.SUCCESS, actual.code()); System.out.println(actual.message().get(0).getData()); - Assert.assertEquals(gt, actual.message().get(0).getData()); + assertEqualsNonStrict(gt, actual.message().get(0).getData()); } @Test @@ -358,7 +362,7 @@ public void testShowAllTTL() { String gt = "storage group\tttl\n" + "root.test.wf02\tnull\n" + "root.test.wf01\t12345"; Assert.assertNotNull(actual); Assert.assertEquals(Code.SUCCESS, actual.code()); - Assert.assertEquals(gt, actual.message().get(0).getData()); + assertEqualsNonStrict(gt, actual.message().get(0).getData()); } @Test @@ -377,7 +381,7 @@ public void testShowStorageGroup() { String gt = "storage group\n" + "root.test.wf02\n" + "root.test.wf01"; Assert.assertNotNull(actual); Assert.assertEquals(Code.SUCCESS, actual.code()); - Assert.assertEquals(gt, actual.message().get(0).getData()); + assertEqualsNonStrict(gt, actual.message().get(0).getData()); } @Test @@ -389,4 +393,11 @@ public void testListUser() { Assert.assertEquals(Code.SUCCESS, actual.code()); Assert.assertEquals(gt, actual.message().get(0).getData()); } + + private void assertEqualsNonStrict(String gt, String actual) { + List actualList = new ArrayList(Arrays.asList(actual.split("\n"))); + List expectedList = new ArrayList(Arrays.asList(gt.split("\n"))); + Assert.assertEquals(expectedList.get(0), actualList.get(0)); + Assert.assertEquals(new HashSet(expectedList), new HashSet(actualList)); + } }