通过 API 提交 Dataproc 作业答案

【问题标题】：Dataproc Job Submit Via API通过 API 提交 Dataproc 作业
【发布时间】：2022-01-26 10:43:40
【问题描述】：

我正在运行流式作业，它将永远运行并将执行关于 Kafka 主题的查询，我正在查看 DataProc 文档以通过 Java 提交作业，这里是 link

 // Submit an asynchronous request to execute the job.
      OperationFuture<Job, JobMetadata> submitJobAsOperationAsyncRequest =
          jobControllerClient.submitJobAsOperationAsync(projectId, region, job);

      Job response = submitJobAsOperationAsyncRequest.get();

对于上面的代码行我无法得到response，上面的代码继续运行吗？是因为它是流式作业并且一直在运行吗？

我怎样才能得到回应？因此，对于最终用户，我可以提供一些工作信息，例如 URL，他们可以在其中看到他们的工作或任何监控仪表盘

【问题讨论】：

标签： java google-cloud-platform google-cloud-dataproc

【解决方案1】：

OperationFuture<Job, JobMetadata> 类有一个getMetadata() 方法，它返回一个com.google.api.core.ApiFuture<JobMetadata>。您可以通过调用jobMetadataApiFuture.get() 在作业完成之前获取作业元数据。

查看有关OperationFuture.getMetadata() 方法和ApiFuture 类的更多详细信息。

【讨论】：