为 Cloud Data Fusion Managed Service for Apache Spark 集群启用 Cloud Logging 后,您除了可以访问标准流水线指标外,还可以访问精细的执行记录。您可以使用这些高级日志来排查运行失败问题、检查驱动程序和执行器行为,以及调试复杂的数据转换。
启用 Managed Service for Apache Spark Cloud Logging
如需在 Cloud Logging 中查看流水线和集群问题,请在新 Cloud Data Fusion 实例或现有 Cloud Data Fusion 实例中启用高级日志。如需在现有实例中启用高级日志,请执行以下操作:
在 Google Cloud 控制台中,前往 Cloud Data Fusion 实例页面。
点击实例名称。
在高级监控和日志记录部分中,点击 Dataproc Cloud Logging 对应的 修改。
在 Cloud Logging 窗口中,选中启用 Cloud Logging 复选框。
点击保存。
查看日志
每个 Cloud Data Fusion 流水线运行都会分配一个唯一的 RunID。部署并运行流水线后,找到其 RunID。然后,在 Logging 中使用 RunID 查看流水线日志。
获取流水线的 RunID
- 前往您的实例:
在 Google Cloud 控制台中,前往 Cloud Data Fusion 页面。
如需在 Cloud Data Fusion Studio 中打开实例,请点击实例,然后点击查看实例。
- 点击列表。
- 点击要获取其运行 ID 的流水线。
- 点击摘要。
- 在运行记录部分中,点击表格。
- 如需复制运行 ID,请右键点击 RunID,然后点击复制。
在 Logs Explorer 中查看日志
在 Google Cloud 控制台中,前往 Cloud Logging > Logs Explorer 页面:
在所有资源下拉菜单中,选择 Cloud Dataproc 集群 >
cdap-PIPELINE_NAME-YOUR_RUNID。
可选:过滤日志
使用过滤条件菜单过滤日志。您可以按各种日志严重级别或按组件(例如 datafusion-pipeline-logs)进行过滤。
可选:下载日志
点击下载日志。
如需了解详情,请参阅下载日志条目。