故障排除 - Amazon Kinesis Data Analytics
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 Amazon Web Services 服务入门

本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。

故障排除

本节包含 Studio 笔记本电脑的故障排除信息。

停止卡住的应用程序

要停止处于暂时状态的应用程序,请调用StopApplication使用Force将参数设置为true. 有关更多信息,请参阅 。运行应用中的Kinesis Data Analytics 开发者指南.

取消任务

本节将向您展示如何取消 Apache Flink 无法从 Apache Zeppelin 获得的工作。如果你想取消这样的作业,请转到 Apache Flink 控制面板,复制作业 ID,然后在以下示例之一中使用它。

要取消单个任务:

%flink.pyflink import requests requests.patch("https://zeppelin-flink:8082/jobs/[job_id]", verify=False)

要取消所有正在运行的作业:

%flink.pyflink import requests r = requests.get("https://zeppelin-flink:8082/jobs", verify=False) jobs = r.json()['jobs'] for job in jobs: if (job["status"] == "RUNNING"): print(requests.patch("https://zeppelin-flink:8082/jobs/{}".format(job["id"]), verify=False))

要取消所有作业:

%flink.pyflink import requests r = requests.get("https://zeppelin-flink:8082/jobs", verify=False) jobs = r.json()['jobs'] for job in jobs: requests.patch("https://zeppelin-flink:8082/jobs/{}".format(job["id"]), verify=False)

重新启动 Apache Flink 解释器

在你的 Studio 笔记本中重新启动 Apache Flink 解释器

  1. 选择配置靠近屏幕右上角。

  2. 选择口译员.

  3. 选择重新启动然后确定.