问题标签 [amazon-swf]

我正在 EMR 上执行 Amazon SWF 作业。我想在另一个 EMR 集群中使用这个 EMR 集群 JobFlowID。目前，要将 jar 步骤添加到我正在使用的 EMR 集群

AddJobFlowStepsRequest 请求 = 新的 AddJobFlowStepsRequest(jobFlowId)

我如何在另一个工作流中使用此步骤并调用前一个集群的作业流 id。

我有两台服务器（EC2 实例）。在一台服务器（服务器 1）上我有 5 个批次，而在另一台服务器（服务器 2）上我有 6 个批次。我将每个批次包装成活动，下面给出了工作流程实现类。我想根据给定的执行日期迭代活动（整个活动，包括服务器 1 和 2）。例如，如果日期小于当前日期，则从给定日期到当前日期执行服务器 1 和 2 的所有活动。如果执行日期等于当前日期，则在当前日期执行服务器 1 和 2 的所有活动。此外，如果一天的任何活动引发任何异常，则不要执行第二天的活动（<=当前日期）。

问题是，如果服务器 1 的任何活动引发任何异常，那么它将取消服务器 1 和服务器 2 尚未启动的所有活动。但我只希望服务器内未执行的活动应该得到由于自己的服务器活动失败而取消，其他服务器应尽可能继续（即它所依赖的地方）。

如果数据大小以 kb 为单位，我已经能够执行我的代码以将数据从一个 s3 存储桶复制到另一个 rbucket。但是，如果大小增长到几 mb，我的任务会因 START_To_CLOSE 错误而失败。任务因 taskStarttoClose 超时而失败。我尝试将 defaultTaskStartToCloseTimeoutSeconds 覆盖为 60 秒，稍后在执行工作流时，我看到该值设置为 10 秒。我不明白为什么当我让它等待 60 秒时值会发生变化。该活动无法复制大文件。这是复制活动的代码示例。

我正在使用流框架编写 AWS SWF 应用程序。IllegalStateException: No context Found. It means that the method is called outside of the workflow definition code.调用以下代码一段时间：

为什么我会收到此错误以及如何摆脱它？

我有一些活动，他们可以抛出一些自定义异常。问题是我无法在 Activity Worker 类中捕获抛出的异常，并且正在显示堆栈跟踪。我试图捕捉 Throwable 但没有用，因为堆栈跟踪再次显示。

活动实施班

活动工人阶级

堆栈跟踪

2014 年 10 月 18 日下午 2:02:53

在我的工作流实现中的所有活动都已完成执行或其中任何一个引发任何异常之后，是否有任何方法可以关闭活动和工作流工作者。

我有一个依赖于N个活动的活动（比如 actN）。所有N个活动都是并行执行的。完成所有活动后，我想执行活动 actN。我想在不使用任何 @Asynchronous 注释的情况下执行此操作，因为 @Asynchronous 标记对我不起作用。

我有三组。前两组可以并行执行。第三组只有在第一组和第二组执行成功后才能执行。问题是它们都是随机执行的。没有这样的编排。

包：com.myco.test

src/main/resources/aop.xml

pom.xml

默认虚拟机参数：

-javaagent:C:\aspectj1.7\lib\aspectjweaver.jar

我的 Amazon Simple 工作流程旋转 EMR 集群并添加一些步骤，这些步骤取决于上一步的输出。如果我有 10 个步骤，并说我的第 6 步在 s3 中生成输出，应该由第 7 步查看以确定该步骤是否可以进一步继续或根据第 6 步输出终止集群。我的工作流程运行良好，但是如果输出不理想，我该如何终止集群。我正在使用 AWS java sdk。

我有两组需要并行执行的活动。在他们成功完成后，我想执行另一组活动。我使用了Task，它正在工作。但是，在使用 @Asynchronous 注释后，我得到了 DecisionTaskTimedOut 并且没有任何活动开始执行。我的 aspectj 配置正在工作，因为我可以在我的目标中看到以下类：

AsyncWorkflowImpl$AjcClosure1.class

AsyncWorkflowImpl$AjcClosure3.class

AsyncWorkflowImpl$AjcClosure5.class

异步版本

任务版本

aspectj编织有什么问题吗？任何建议都受到高度赞赏。