luoluoyuyu commented on code in PR #17756:
URL: https://github.com/apache/iotdb/pull/17756#discussion_r3309366943
##########
integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeAutoSplitIT.java:
##########
@@ -161,4 +157,18 @@ public void testSingleEnv() throws Exception {
"Time,root.test.device.field,",
Collections.singleton("1,2.0,"));
}
+
+ private void assertAutoSplitResult(
+ final List<TShowPipeInfo> showPipeResult, final String pipeName) {
+ // The history pipe may have already been auto-dropped after snapshot
transfer completes.
+ Assert.assertTrue(
+ showPipeResult.stream().anyMatch(i -> Objects.equals(i.id, pipeName +
"_realtime")));
+ Assert.assertFalse(showPipeResult.stream().anyMatch(i ->
Objects.equals(i.id, pipeName)));
Review Comment:
nit: Assert.assertFalse(showPipeResult.stream().anyMatch(...)) can be
written as assertTrue(showPipeResult.stream().noneMatch(i ->
Objects.equals(i.id, pipeName))) for readability. Not blocking.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
