问题标签 [spring-cloud-task]

我见过的每个示例（task-launchersink 和triggertasksource ）都展示了如何启动由uri属性定义的任务。我的任务定义如下所示：

我的问题是如何sampleTaskRunner从流应用程序启动组合任务运行程序（由 DSL 定义）。

谢谢

更新

我最终得到了以下使用 SCDF REST API 触发任务的解决方案：

composedTask定义 ：

<timestamp || mySampleTask>

流定义：

http | httpclient | log

部署属性：

虽然实现组件很容易http sink，但如果流应用程序启动器能够提供一个开箱即用的组件，那就太好了。

我担心的另一个问题是在分布式环境中部署时发现 SCDF REST URL。

我是 spring-batch 和 spring 云数据流的新手。我修改了 spring-batch 的示例快速启动项目，它现在写入本地 MSSQL 数据库：当我使用 java -jar 运行它时它工作正常。我现在尝试将它部署到 Spring Cloud Data Flow 的本地实例，从仪表板将其作为任务导入并尝试运行：它给了我这个错误：

当部署为 Stream 时，相同的 spring-batch uber-jar 工作：我错过了什么？

我正在模拟组合任务的错误处理行为，failedTask组合任务定义如下所示：

<f1: sampleTask --fail=true --custom-argument=someMessage || f2: sampleTask>

sampleTask班级跑者：

依赖项：

问题是结束时间f1不是数据库中的记录器，failedTask状态显示STARTED在仪表板 UI 中，end_time并且failedTask在表failedTask-f1中都是空的。task_executions

以下是f1执行日志：

如果我删除

依赖项 - 以下警告日志消息消失，一切都按预期工作。

2017-11-20 12:09:06.920 WARN 28244 --- [ main] o.s.b.f.support.DisposableBeanAdapter : Invocation of destroy method failed on bean with name 'taskLifecycleListener': org.springframework.messaging.converter.MessageConversionException: failed to convert object to Message; nested exception is org.springframework.messaging.MessagingException: At most one parameter (or expression via method-level @Payload) may be mapped to the payload or Message. Found more than one on method [public abstract void org.springframework.cloud.task.listener.TaskExecutionListener.onTaskFailed(org.springframework.cloud.task.repository.TaskExecution,java.lang.Throwable)]

请指教。

我在组合任务执行侦听器之后，它将事件发布到中间件，基本上，与此处为自定义任务记录的行为相同

有没有办法为通过 SCDF REST API 运行的组合任务启用此功能？

谢谢

我有myFailedTask2 个步骤的组合任务，其中一个配置为始终失败： <mf1: sampleTask --fail=true --custom-argument=m || sampleTask> 第一次运行时，作业以run.id等于1运行，并mf1报告为失败。下次我运行 CTR 时，作业再次 以run.id等于1sampleTask的方式运行，并 跳过步骤：

我正在使用使用httpclient以下属性文件部署的转换器执行 CTR：

我还在--composed-task-argumentsCTR 调用之间通过不同的有效负载更改了 - 效果相同。

所以，我的问题是如何强制 CTR 运行新作业，而不是从失败的步骤继续之前失败的作业。

更新

好的，深入研究 spring 源代码，下面的代码JobLauncherCommandLineRunner::getNextJobParameters解释了这种行为：

所以我改写原来的问题：“我怎样才能将restartable属性传递给 CTR ？

我在基于 spring-cloud-task 的应用程序中运行 junit 测试时遇到奇怪的错误，并且无法找到原因。

这是我的测试类的片段，后跟错误堆栈跟踪。我注意到删除 @EnableTask 注释运行测试没有问题。

有人有什么建议吗？

谢谢

这里是堆栈跟踪：

我们正在将我们的工作和流从 Spring XD 迁移到 Kubernetes 上的 Spring 云数据流。

Spring Cloud 数据流是否有商业支持？任何链接都有帮助。

在过去的几年里，我们有使用 Spring XD 的经验，现在正在迁移到 Spring Cloud Data Flow。我们使用 Oracle RAC 集群作为作业存储库（用于数据库级别的 HA）。

要通过 Oracle RAC 获得真正的 HA，JDBC 客户端需要使用连接池配置和 Oracle 快速连接故障转移 (FCF) 来获得有关 Oracle 节点故障的事件通知。

我们是否支持云数据流自定义连接池，以便我们可以包含 FCF 配置？

我是 Spring Cloud Task 的新手。我正在尝试设置 Hello World 示例应用程序。它运行并且按照这里的示例一切似乎都很好。但是我看到下面的输出。我看到一些 slf4j 警告。但是我的理解是 spring boot 应该提供默认设置。为什么我看到不同的日志文件有什么原因？

我的application.properties已经有了这个。

编辑 当我在我的 pom 中添加 spring 批处理启动器时，日志开始显示正常并且 slf4j 警告消失了。如果我们只有 spring 云任务，我猜想 slf4j 配置会丢失。是否有任何特定原因将其配置为特定于 Spring Cloud 任务？

我们可以运行一个集成了 Spring Cloud 数据流的 Spring Batch 基于 Web 的应用程序吗？我正在尝试将 SCDF 集成到现有的基于 Web 的 Spring Batch 项目中。这是我的 pom.xml 文件

我的主类用@EnableTask 注释

如果我运行应用程序。我收到一条日志消息，

osbceAnnotationConfigEmbeddedWebApplicationContext - 关闭 org.springframework.boot.context.embedded.AnnotationConfigEmbeddedWebApplicationContext@5fe94a96：启动日期 [Tue Jan 02 16:43:56 IST 2018]；上下文层次的根

所以我的应用程序没有在嵌入式 tomcat 中运行。如果我删除 @EnableTask 注释，它会令人惊讶地工作。请帮我解决这个问题