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

Question

TL;DR

Spring Cloud Data Flow 不允许多次执行同一任务，即使 documentation 表示这是默认行为。我们如何允许 SCDF 使用 Java DSL 启动任务同时运行同一任务的多个实例？为了让事情变得更有趣，例如使用 curl 直接点击其余的点时，多次启动相同的任务效果很好。

背景：

我有一个 Spring 云数据流任务，我已经在 Spring Cloud Data Flow UI Dashboard

中预先注册了

@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 命令，我可以启动同一任务的多个实例

问题：

根据SCDF Task documentation，一个任务可以默认重新运行。不需要额外的配置就可以重新运行同样的任务；然而，事实似乎恰恰相反。默认情况下，SCDF 不允许重新运行任务？
我尝试按照建议添加 Spring 集成 jar，并明确将 spring.cloud.task.single-instance-enabled 属性设置为 false 但开始运行ning 进入 NoClassDefFoundError 相关问题。我也尝试将此属性传递给 Task.launch 方法，但这并没有解决问题。
为什么同一个任务使用curl命令可以多次重启，而使用Java DSL却不能多次重启？

Answer 1

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

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<>());

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

Spring Cloud Data Flow : Unable to launch multiple instances of the same Task

java

spring-cloud-task

spring-cloud-dataflow