@Test
    public void testCheckHasCircle() {
        StreamPipeline streamPipeline = new StreamPipeline();
        streamPipeline.addRelation(new StreamNodeRelation(Sets.newHashSet("A", "B"), Sets.newHashSet("C")));
        streamPipeline.addRelation(new StreamNodeRelation(Sets.newHashSet("C"), Sets.newHashSet("D")));
        streamPipeline.addRelation(new StreamNodeRelation(Sets.newHashSet("D"), Sets.newHashSet("E", "F")));
        streamPipeline.addRelation(new StreamNodeRelation(Sets.newHashSet("F"), Sets.newHashSet("G")));
        streamPipeline.addRelation(new StreamNodeRelation(Sets.newHashSet("E"), Sets.newHashSet("H", "C")));
        Pair<Boolean, Pair<String, String>> circleState = streamPipeline.hasCircle();
        Assertions.assertTrue(circleState.getLeft());
        Assertions.assertTrue(Sets.newHashSet("E", "C").contains(circleState.getRight().getLeft()));
        Assertions.assertTrue(Sets.newHashSet("E", "C").contains(circleState.getRight().getRight()));
    }
Stream pipeline service test for check has circle.
inlong-manager/manager-pojo/src/test/java/org/apache/inlong/manager/pojo/stream/StreamPipelineTest.java