@Test
    public void testRematchedWhenSuspend() {
        final Pair<String, String> groupStream = saveSource("group1,group3");
        bindGroup(true, "group1");

        agent.pullTask();
        agent.pullTask(); // report last success status

        // mismatch and rematch
        bindGroup(false, "group1");
        agent.pullTask();
        agent.pullTask(); // report last to make it from 304 -> 104
        bindGroup(true, "group1");

        // suspend
        suspendSource(groupStream.getLeft(), groupStream.getRight());
        TaskResult taskResult = agent.pullTask();
        Assertions.assertEquals(0, taskResult.getDataConfigs().size());
    }
Test node group rematch source task but group suspend
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/core/impl/AgentServiceTest.java