@BeforeEach
    public void setupEach() {
        agent = new MockAgent(agentService, heartbeatService, 2);
        agent.sendHeartbeat();
        groupStreamCache = new ArrayList<>();
        groupCache = new ArrayList<>();
        super.login();
    }
mock {@link InlongGroupProcessService#restartProcessAsync}, it will restart stream source
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/core/impl/AgentServiceTest.java