Clean e2e tests

GoogleCloudDataproc · Jan 14, 2025 · 7883d9d · 7883d9d
1 parent 3b3a43f
commit 7883d9d
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/cloudbuild/nightly/cloudbuild.yaml b/cloudbuild/nightly/cloudbuild.yaml
@@ -163,7 +163,7 @@ steps:
       - 'GCS_JAR_LOCATION=${_GCS_JAR_LOCATION}'
       - 'PROJECT_ID=${_PROJECT_ID}'
       - 'PROJECT_NAME=${_PROJECT_NAME}'
-      - 'DATASET_NAME=${_DATASET_NAME}'
+      - 'DATASET_NAME=${_WRITE_DATASET_NAME}'
       - 'QUERY=${_QUERY}'
       - 'PROPERTIES_SMALL_BOUNDED_JOB=${_PROPERTIES_SMALL_BOUNDED_JOB}'
       - 'REGION_SMALL_TEST_FILE=${_REGION_SMALL_TEST_FILE}'

diff --git a/...examples/src/main/java/com/google/cloud/flink/bigquery/examples/BigQueryTableExample.java b/...examples/src/main/java/com/google/cloud/flink/bigquery/examples/BigQueryTableExample.java
@@ -52,7 +52,6 @@
  *       at the time of execution, analogous to a batch job. Unbounded source implies that the BQ
  *       table will be periodically polled for new data. Resulting records can be written to another
  *       BQ table, with allowed delivery (write) guarantees at-least-once or exactly-once. <br>
- *       The sequence of operations in both pipelines is: <i>source > flatMap > sink</i> <br>
  *       Flink command line format is: <br>
  *       <code> flink run {additional runtime params} {path to this jar}/BigQueryTableExample.jar
  *       </code> <br>