如何停止Spring Cloud数据流中的一个任务？
共有1个答案
可能您正在运行一个快速完成的批处理作业。
也许您可以有一个示例来模拟长时间运行的批处理作业的行为（例如：运行5分钟或更长时间的作业）；对于这种类型的应用程序，启动后，您可以切换到“作业”选项卡以选择“停止作业”选项来停止当前运行的批处理作业。
以下是供参考的视觉切换：
-
stop-task 命令用于停止数据迁移任务。有关 stop-task 与 pause-task 的区别，请参考暂停数据迁移任务中的相关说明。 help stop-task stop a specified task Usage: dmctl stop-task [-s source ...] <task-name | task-file> [flags] Flags: -h, --hel
-
一旦找到匹配项（在本例中为16)，不会立即返回，而是阻塞，直到剩余的线程完成。在这种情况下，调用方在找到匹配项后返回之前将额外等待5秒。
-
我已经使用Spring云数据流来控制一些批处理作业。在SCDF中，我定义了一些任务后，它们作为运行状态的作业启动。当我试图停止一项特定的工作时，它并没有立即停止。我发现该工作仍在运行，直到它完成了当前的步骤。 例如，我的作业'abc'有2个步骤A和B。在SCDF中，当步骤A正在执行，而作业'abc'仍在运行时，我停止作业'abc'，直到步骤A完成，并且它没有实现步骤B。 那么，有什么方法可以从Sp
-
我有一个spark流媒体作业，它每5秒钟读取一次Kafka，对传入的数据进行一些转换，然后写入文件系统。 这实际上不需要是一个流式作业，实际上，我只想每天运行一次，将消息排入文件系统。但我不知道如何停止这项工作。 如果我向streamingContext传递超时。等待终止，它不会停止进程，它所做的只是导致进程在流上迭代时产生错误（请参见下面的错误） 实现我所要做的事情的最佳方式是什么 这是Pyth
-
问题内容： 我正在使用类，并且正在使用其schedule方法执行某些任务，但是在执行了6次之后，我必须停止其任务。 我该怎么办？ 问题答案： 在某个地方保留对计时器的引用，并使用： 停止所做的一切。您可以将此代码放在正在执行的任务中，以计算您经过的次数，例如
-
问题内容： 我正在使用类，并且正在使用其schedule方法执行某些任务，但是在执行了6次之后，我必须停止其任务。 我该怎么办？ 问题答案： 在某个地方保留对计时器的引用，并使用： 停止所做的一切。您可以将此代码放在要执行的任务中，static int以计算您经过的次数，例如
-
我正在尝试使用TkinterGUI使用python/tweepy来流式传输推文。理想情况下，我会有一个启动流的“开始”按钮和一个停止流的“停止”按钮。下一个示例（来自stackoverflow）以一种简化的方式展示了我试图实现的目标： 我试图将此应用到我的代码中，开始按钮工作正常，完成了它应该做的所有事情，但停止按钮没有做任何事情。窗口没有冻结或任何东西，只是停止按钮没有效果。由于什么事也没有发生
-
通过使用会话窗口与相当高级的组一起运行流数据流管道，在运行几个小时后，我遇到了问题。工作在workers中扩展，但后来开始获得日志负载，其内容如下 记录此代码的转换位于“group by”-块之后，并执行对外部服务的异步HTTP调用（使用)。 你知道为什么会这样吗？与异步、伸缩或按策略分组有关？ 作业ID:2018-01-29_03_13_40-12789475517328084866 SDK：A