SCDF数据流服务器2.4.2组成任务

Question

我将SCDF与跳过服务器2.3.2和数据流服务器2.4.2一起使用。与Docker-compose一起部署我使用composite-task-runner 2.1.3版本构建了任务我尝试执行任务，但是即使使用示例，composite-task-runner也不会启动任务

示例：

composed-task-runner && mytask && myTask

2020-04-14 14:40:41.633  INFO 231 --- [           main] o.s.s.concurrent.ThreadPoolTaskExecutor  : Initializing ExecutorService 'taskExecutor'
2020-04-14 14:40:41.752  INFO 231 --- [           main] o.s.b.c.r.s.JobRepositoryFactoryBean     : No database type set, using meta data indicating: POSTGRES
2020-04-14 14:40:41.885  INFO 231 --- [           main] o.s.b.c.l.support.SimpleJobLauncher      : No TaskExecutor has been set, defaulting to synchronous executor.
2020-04-14 14:40:42.083 DEBUG 231 --- [           main] o.s.c.t.a.c.DataFlowConfiguration        : Not configuring basic security for accessing the Data Flow Server
2020-04-14 14:40:46.922 DEBUG 231 --- [           main] o.s.c.t.r.s.TaskRepositoryInitializer    : Initializing task schema for postgresql database
2020-04-14 14:40:47.461 DEBUG 231 --- [           main] BatchConfiguration$ReferenceTargetSource : Initializing lazy target object
2020-04-14 14:40:47.552 DEBUG 231 --- [           main] o.s.c.t.r.support.SimpleTaskRepository   : Starting: TaskExecution{executionId=102, parentExecutionId=null, exitCode=null, taskName='testComposedTask2', startTime=Tue Apr 14 14:40:47 GMT 2020, endTime=null, exitMessage='null', externalExecutionId='null', errorMessage='null', arguments=[xx=7777, --spring.cloud.data.flow.platformname=default, --spring.cloud.task.executionid=102, --spring.cloud.data.flow.taskappname=composed-task-runner]}
2020-04-14 14:40:47.675  INFO 231 --- [           main] .t.a.c.ComposedtaskrunnerTaskApplication : Started ComposedtaskrunnerTaskApplication in 33.768 seconds (JVM running for 38.059)
2020-04-14 14:40:47.743 DEBUG 231 --- [           main] o.s.c.t.r.support.SimpleTaskRepository   : Updating: TaskExecution with executionId=102 with the following {exitCode=0, endTime=Tue Apr 14 14:40:47 GMT 2020, exitMessage='null', errorMessage='null'}
2020-04-14 14:40:47.831  INFO 231 --- [       Thread-7] o.s.s.concurrent.ThreadPoolTaskExecutor  : Shutting down ExecutorService 'taskExecutor'
2020-04-14 14:40:47.836  INFO 231 --- [       Thread-7] j.LocalContainerEntityManagerFactoryBean : Closing JPA EntityManagerFactory for persistence unit 'default'
2020-04-14 14:40:47.852  INFO 231 --- [       Thread-7] com.zaxxer.hikari.HikariDataSource       : HikariPool-1 - Shutdown initiated...
2020-04-14 14:40:47.909  INFO 231 --- [       Thread-7] com.zaxxer.hikari.HikariDataSource       : HikariPool-1 - Shutdown completed.

您能帮我吗？我在使用Postgres DB

新备注：

我按照文档中的说明构建了一个新的合成任务：

具有定义myTask &&时间戳的testComposedTaskA

数据流：>任务列表

╔═══════════════════════════╤═══════════════════╤═══════════╤═══════════╗
║         Task Name         │  Task Definition  │description│Task Status║
╠═══════════════════════════╪═══════════════════╪═══════════╪═══════════╣
║testComposedTaskA-myTask   │myTask             │           │UNKNOWN    ║
║testComposedTaskA-timestamp│timestamp          │           │UNKNOWN    ║
║testComposedTaskA          │myTask && timestamp│           │UNKNOWN    ║
╚═══════════════════════════╧═══════════════════╧═══════════╧═══════════╝

数据流：>任务启动testComposedTaskA启动任务“ testComposedTaskA”，执行ID为135

数据流：>任务执行列表

╔═════════════════╤═══╤════════════════════════════╤════════════════════════════╤═════════╗
║    Task Name    │ID │         Start Time         │          End Time          │Exit Code║
╠═════════════════╪═══╪════════════════════════════╪════════════════════════════╪═════════╣
║testComposedTaskA│135│Fri Apr 17 15:04:42 GMT 2020│Fri Apr 17 15:04:42 GMT 2020│0        ║
╚═════════════════╧═══╧════════════════════════════╧════════════════════════════╧═════════╝

子任务从不执行。在示例中，我们可以看到子任务已执行怎么了？

问候

Frederic

Answer 1

从日志：composed-task-runner && mytask && myTask，用于创建组合任务定义的语法看起来不正确。

应用程序名称composed-task-runner不应成为任务DSL的一部分。

您可以在here中找到有关如何创建和管理组合任务的详细文档。