如何立即停止Spring云数据流中的作业
我已经使用Spring云数据流来控制一些批处理作业。在SCDF中，我定义了一些任务后，它们作为运行状态的作业启动。当我试图停止一项特定的工作时，它并没有立即停止。我发现该工作仍在运行，直到它完成了当前的步骤。
例如，我的作业'abc'有2个步骤A和B。在SCDF中，当步骤A正在执行，而作业'abc'仍在运行时，我停止作业'abc'，直到步骤A完成，并且它没有实现步骤B。
那么，有什么方法可以从Spring Cloud Data Flow中立即停止作业吗？
共有1个答案
从Spring Cloud数据流中，批处理作业stop操作被委托给Spring batch API。这意味着Spring Cloud Data Flow不能立即停止批处理作业，因为它需要由Spring批处理或作业实现本身来处理。
当为批处理作业执行发送批处理作业stop请求时（如果它正在运行），当前步骤执行将使用标志terminateonly设置为true，这意味着根据底层步骤执行实现可以停止步骤执行。
-
问题内容： 我正在使用SQL Server 2008及其管理工作室。我执行了一个查询，该查询产生许多行。我试图通过红色的“取消”按钮将其取消，但在过去的10分钟内仍未停止。通常会在3分钟内停止。 原因可能是什么？如何立即停止？ 问题答案： 可能是什么原因 只要您的注意力可以到达服务器并得到处理，查询就会立即取消。查询必须处于可取消状态，几乎总是如此，除非您执行某些操作，例如从SQLCLR调用Web
-
我的应用程序设置为（非故意）服务将使用gps/网络侦听器轮询位置。它工作得很好，因为我负责服务何时结束（即在找到新位置或达到超时时调用stopSelf（））。然而，我最近读到，intentService可能更适合长时间运行的任务，因为它不是在ui线程上运行的，而是在自己的工作线程上运行的。问题是，现在它不允许服务在任何时间运行（我假设这是因为服务中没有任何活动发生，而侦听器等待接收位置，因此服务本
-
问题内容： 我尝试了一切。这也是一个如何停止Java.util.Timer类中计划的任务 我有一个实现java.util.TimerTask的任务 我用两种方式称呼该任务： 我这样安排计时器： timer.schedule（timerTask，60 * 1000）; 有时我需要立即开始工作，并且如果有正在工作的工作，必须取消timerTask cancelCurrentWork（）; timer.
-
通过使用会话窗口与相当高级的组一起运行流数据流管道，在运行几个小时后，我遇到了问题。工作在workers中扩展，但后来开始获得日志负载，其内容如下 记录此代码的转换位于“group by”-块之后，并执行对外部服务的异步HTTP调用（使用)。 你知道为什么会这样吗？与异步、伸缩或按策略分组有关？ 作业ID:2018-01-29_03_13_40-12789475517328084866 SDK：A
-
我正在尝试为Flink流媒体作业创建JUnit测试，该作业将数据写入kafka主题，并分别使用和从同一kafka主题读取数据。我正在通过生产中的测试数据： 以及检查来自消费者的数据是否与以下数据相同： 使用。 通过打印流，我能够看到来自消费者的数据。但无法获得Junit测试结果，因为即使消息完成，使用者仍将继续运行。所以它并没有来测试这个部件。 在或中是否有任何方法停止进程或运行特定时间？