@Override
    public StreamInfo getTestObject() {
        Node input = buildMySqlExtractNode();
        Node output = buildKafkaNode();
        return new StreamInfo("1", Arrays.asList(input, output), Collections.singletonList(
                buildNodeRelation(Collections.singletonList(input), Collections.singletonList(output))));
    }
Get test object

@return The test object
inlong-sort/sort-common/src/test/java/org/apache/inlong/sort/protocol/StreamInfoTest.java