@Transactional(rollbackFor = Throwable.class)
    public void processInstall() {
        LOGGER.info("begin to process install task");
        while (!pendingInstallRequests.isEmpty()) {
            ClusterNodeRequest request = pendingInstallRequests.poll();
            InstallTaskRunnable installTaskRunnable = new InstallTaskRunnable(request);
            executorService.execute(installTaskRunnable);
        }
        LOGGER.info("success to process install task");
    }
Make sure there is no InlongGroup using this tag.
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/InlongClusterServiceImpl.java