当前位置: 首页 > 知识库问答 >
问题:

春云数据流 - 组合任务运行器不启动第二个任务

林冥夜
2023-03-14

我有一个由两个连续批处理作业组成的数据流管道。第一批成功完成,但是第二批没有开始。< br >我已经使用嵌入式H2数据库启动了数据流服务器。我已经通过application.properties将Spring Batch指向同一个H2html" target="_blank">实例。< br >我的composed-task-runner应用程序似乎正确地获取了数据流的数据源。我可以看到它继承了数据流服务器,道具显示在仪表板的任务执行部分。日志中没有错误。仅记录成功执行第一批的条目。< br >我的任务执行条目:< br >

问题可能是什么?为什么第一步的TASK_EXECUTION表中有两个条目?根据task_name-这些条目仅属于第一批处理步骤。

共有1个答案

相高谊
2023-03-14

我能够通过使用Spring Initialzr重新构建我的批处理任务来解决这个问题。最初,我尝试使用spring-cloud-task-app-starters作为我工作的基础,这可能不是构建数据流任务的正确方法。

 类似资料:
  • 我有一个从流-任务-启动器-数据流调用的组合任务 我将流处理器中的几个属性传递给任务启动器数据流和子任务,例如。。。 这可以正常工作,但我已经达到了最大字符限制,并在组合任务pod上得到一个sql异常,说明我已经超过了2500个字符的限制。我想为所有任务而不是单独设置属性以节省字符空间,但使用通配符不起作用 有没有办法为所有任务设置属性,而不必单独设置? 我尝试在kubernetes中的Sprin

  • 目前,我正在从Spring XD作为我的工作流和运行时环境转移到Spring Cloud DataFlow和Apache Airflow。我想在Airflow中创建工作流,并使用自定义的Airflow操作员通过REST-API在Spring Cloud DataFlow服务器上运行Spring Cloud任务。 可以使用: 不幸的是,DataFlow在此请求中不返回作业执行ID,以创建用于监视应用

  • 我实现了Spring云任务示例中给出的示例批处理作业示例。其中使用的 Spring 引导版本是 2.0.1.RELEASE。由于我必须移植另一个作业,因此我必须启动云任务,因此我想找到兼容的最旧版本。使用 1.3.2.RELEASE 创建的批处理作业的 jar 作为 Spring 引导版本成功运行。但是当我在将其添加为应用程序后从 Spring 云数据流的 UI 运行它时,出现以下错误:

  • 我在Openshift集群上安装了一个Spring Cloud数据流。我尝试注册一个应用程序,然后创建一个任务,一切都很好,但当我试图安排任务时,我遇到了以下异常: 我不知道这是什么意思,我是Dataflow的新手。我不明白为什么他试图使用Maven而不是kubernetes部署器,也不明白为什么我会出现这个错误。有人能再给我解释一下吗? 顺便说一句,我将这些应用程序注册为docker容器。

  • 我试图了解运行批处理任务时通过Spring Cloud数据流WRT数据源配置的预期行为。 Spring批处理数据库表(Batch\u JOB\u EXECUTION等)是否在SCDF数据库本身中?当通过SCDF启动任务时,似乎发生了一些神奇的事情,它在SCDF数据库中创建了这些表,并似乎在使用它们。它似乎正在将SCDF数据源注入我的应用程序? 我目前在localhost服务器版本2.0.1上运行。

  • 每次我们启动spring云任务时,它都会启动一个新的jvm(java.exe),所以如果启动了25个任务,那么它就会启动25个jvm。 我想知道如何同时限制所有任务(为所有部署的JAR运行)的总数? 假设我必须将一次运行的所有任务的总数限制为25个。在SCDF中有什么设置我们可以做到这一点吗? 请让我知道

  • 启动没有参数的时间戳任务应用程序失败。来自Spring Cloud Data Flow Server的日志显示了以下堆栈跟踪:https://gist.github.com/anonymous/420f3928b7831a11b378fc6792be1ffc。 运行输出 则生成

  • 上周,我安装了基于Docker/Kubernetes的Spring Cloud数据流版本 虽然没有明显的错误,但事情并不正常。 我可以在web UI和Spring Cloud数据流Shell中创建流和任务,但没有运行。 我对任务最感兴趣。