Spring Cloud Data Flow：无法启动同一任务的多个实例

如何解决Spring Cloud Data Flow：无法启动同一任务的多个实例

TL;DR

Spring Cloud Data Flow 不允许多次执行同一任务，即使 documentation 表示这是默认行为。我们如何允许 SCDF 使用 Java DSL 同时运行同一任务的多个实例来启动任务？为了让事情变得更有趣，例如，当使用 curl 直接命中其余端点时，多次启动相同的任务可以正常工作。

背景：

我有一个在 Spring Cloud Data Flow UI Dashboard 中预先注册的 Spring Cloud Data Flow Task

@SpringBootApplication
@EnableTask
public class TaskApplication implements ApplicationRunner {

    private static final Logger LOGGER = LoggerFactory.getLogger(TaskApplication.class);

    public static void main(String[] args) {
        SpringApplication.run(TaskApplication.class,args);
    }

    @Override
    public void run(ApplicationArguments args) throws InterruptedException {
        //Some application code
    }
    
}

我正在其他一些主程序中使用 Task Java DSL 启动此任务：

URI dataFlowUri = URI.create(scdfUri);
DataFlowOperations dataFlowOperations = new DataFlowTemplate(dataFlowUri);
Task task = Task.builder(dataFlowOperations).name("Task1").deFinition("a:task1")
                .description("Task launched from DSL").build();         
long executionId = task.launch(new ArrayList<>());

这第一次运行得很好；但是，当我尝试重新运行上述代码时，在上述程序中出现以下异常：

[main] DEBUG org.springframework.web.client.RestTemplate - Response 409 CONFLICT

SCDF 服务器日志显示了类似的问题：

2021-05-12 15:12:31.387  WARN 1 --- [nio-9393-exec-3] o.s.c.d.s.c.RestControllerAdvice         : Caught exception while handling a request: Cannot register task Task1 because another one has already been registered with the same name

有趣的是，如果我使用 API guide 中所示的 curl 命令，我可以启动同一任务的多个实例

问题：

1. 根据SCDF Task documentation，默认情况下可以重新运行任务。无需额外配置即可重新运行相同的任务；然而，事实似乎恰恰相反。 SCDF 默认不允许任务重新运行？

2. 我尝试按照建议添加 Spring 集成 jar，并将 spring.cloud.task.single-instance-enabled 属性显式设置为 false，但开始遇到 NoClassDefFoundError 相关问题。我还尝试将此属性传递给 Task.launch 方法，但这并没有解决问题。

3. 为什么同一个任务在使用 curl 命令时可以多次重新启动，而在使用 Java DSL 时不能多次重新启动？

解决方法

在这种情况下，您似乎正在尝试重新创建任务定义。您应该只需要创建一次任务定义。根据这个定义，您可以多次启动。例如：

URI dataFlowUri = URI.create(scdfUri);
DataFlowOperations dataFlowOperations = new DataFlowTemplate(dataFlowUri);
Task task = Task.builder(dataFlowOperations).name("Task1").definition("a:task1")
                .description("Task launched from DSL").build();         
long executionId = task.launch(new ArrayList<>());
executionId = task.launch(new ArrayList<>());
executionId = task.launch(new ArrayList<>());