时间戳

首页 > 解决方案 > Google Cloud Dataproc 删除 BigQuery 表不起作用

apache-spark - Google Cloud Dataproc 删除 BigQuery 表不起作用

问题描述

您好我尝试使用 Dataproc 中的java 客户端库从 BigQuery 中删除一个表，启动 spark-shell 如下：

spark-shell --packages com.google.cloud:google-cloud-bigquery:1.59.0

并导入以下依赖项

import com.google.cloud.bigquery.BigQuery;
import com.google.cloud.bigquery.BigQueryOptions;
import com.google.cloud.bigquery.FieldValueList;
import com.google.cloud.bigquery.Job;
import com.google.cloud.bigquery.JobId;
import com.google.cloud.bigquery.JobInfo;
import com.google.cloud.bigquery.QueryJobConfiguration;
import com.google.cloud.bigquery.QueryResponse;
import com.google.cloud.bigquery.TableResult;
import java.util.UUID;

val bigquery = BigQueryOptions.getDefaultInstance().getService() 
bigquery.delete("test","temp")

这里 test 和 temp 分别是我的数据集和表名，但在运行上述语句后，它显示以下错误：

java.lang.NoSuchMethodError: com.google.common.util.concurrent.MoreExecutors.directExecutor()Ljava/util/concurrent/Executor;
  at com.google.api.gax.retrying.BasicRetryingFuture.<init>(BasicRetryingFuture.java:82)
  at com.google.api.gax.retrying.DirectRetryingExecutor.createFuture(DirectRetryingExecutor.java:88)
  at com.google.api.gax.retrying.DirectRetryingExecutor.createFuture(DirectRetryingExecutor.java:74)
  at com.google.cloud.RetryHelper.run(RetryHelper.java:75)
  at com.google.cloud.RetryHelper.runWithRetries(RetryHelper.java:50)
  at com.google.cloud.bigquery.BigQueryImpl.delete(BigQueryImpl.java:386)
  at com.google.cloud.bigquery.BigQueryImpl.delete(BigQueryImpl.java:375)
  ... 48 elided

标签： apache-sparkgoogle-cloud-platformgoogle-bigquerygoogle-cloud-dataproc

解决方案

这是因为您在类路径上有一个没有方法的旧Guava 库版本（作为 Hadoop/Spark 依赖项提供）MoreExecutors.directExecutor。

要解决此问题，您需要在应用程序的UberJar中包含和遮蔽/重定位（以避免与类路径上的其他库冲突）google-cloud-bigquery库及其依赖项（包括 Guava）。

这是一个如何使用Maven Shade插件执行此操作的示例。

推荐阅读