You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
### Specifying the Spark BigQuery connector version in a Dataproc cluster
@@ -120,8 +120,8 @@ Using the standard `--jars` or `--packages` (or alternatively, the `spark.jars`/
120
120
121
121
To use another version than the built-in one, please do one of the following:
122
122
123
-
* For Dataproc clusters, using image 2.1 and above, add the following flag on cluster creation to upgrade the version `--metadata SPARK_BQ_CONNECTOR_VERSION=0.34.0`, or `--metadata SPARK_BQ_CONNECTOR_URL=gs://spark-lib/bigquery/spark-3.3-bigquery-0.34.0.jar` to create the cluster with a different jar. The URL can point to any valid connector JAR for the cluster's Spark version.
124
-
* For Dataproc serverless batches, add the following property on batch creation to upgrade the version: `--properties dataproc.sparkBqConnector.version=0.34.0`, or `--properties dataproc.sparkBqConnector.uri=gs://spark-lib/bigquery/spark-3.3-bigquery-0.34.0.jar` to create the batch with a different jar. The URL can point to any valid connector JAR for the runtime's Spark version.
123
+
* For Dataproc clusters, using image 2.1 and above, add the following flag on cluster creation to upgrade the version `--metadata SPARK_BQ_CONNECTOR_VERSION=0.34.1`, or `--metadata SPARK_BQ_CONNECTOR_URL=gs://spark-lib/bigquery/spark-3.3-bigquery-0.34.1.jar` to create the cluster with a different jar. The URL can point to any valid connector JAR for the cluster's Spark version.
124
+
* For Dataproc serverless batches, add the following property on batch creation to upgrade the version: `--properties dataproc.sparkBqConnector.version=0.34.1`, or `--properties dataproc.sparkBqConnector.uri=gs://spark-lib/bigquery/spark-3.3-bigquery-0.34.1.jar` to create the batch with a different jar. The URL can point to any valid connector JAR for the runtime's Spark version.
125
125
126
126
## Hello World Example
127
127
@@ -131,7 +131,7 @@ You can run a simple PySpark wordcount against the API without compilation by ru
131
131
132
132
```
133
133
gcloud dataproc jobs submit pyspark --cluster "$MY_CLUSTER" \
**Note:** To use the metrics in the Spark UI page, you need to make sure the `spark-bigquery-metrics-0.34.0.jar` is the class path before starting the history-server and the connector version is `spark-3.2` or above.
1244
+
**Note:** To use the metrics in the Spark UI page, you need to make sure the `spark-bigquery-metrics-0.34.1.jar` is the class path before starting the history-server and the connector version is `spark-3.2` or above.
0 commit comments