From 3b3a43f4163659584a9b8827a4a8e0998402a49f Mon Sep 17 00:00:00 2001
From: Jayant Jain <jainjayant@google.com>
Date: Thu, 9 Jan 2025 00:23:10 +0530
Subject: [PATCH 1/2] Prepare for next release

---
 pom.xml | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pom.xml b/pom.xml
index 03487169..cd13a080 100644
--- a/pom.xml
+++ b/pom.xml
@@ -73,7 +73,7 @@ under the License.
     </distributionManagement>
 
     <properties>
-        <revision>0.4-SNAPSHOT</revision>
+        <revision>0.5-SNAPSHOT</revision>
         <flink.version>1.17.1</flink.version>
         <bigquery.guava.version>32.1.3-jre</bigquery.guava.version>
         <google-lib-bom.version>26.33.0</google-lib-bom.version>

From 7883d9d323b9bf512ffc726d21aa10a257ec4b19 Mon Sep 17 00:00:00 2001
From: Jayant Jain <jainjayant@google.com>
Date: Tue, 14 Jan 2025 13:20:56 +0530
Subject: [PATCH 2/2] Clean e2e tests

---
 cloudbuild/nightly/cloudbuild.yaml                              | 2 +-
 .../cloud/flink/bigquery/examples/BigQueryTableExample.java     | 1 -
 2 files changed, 1 insertion(+), 2 deletions(-)

diff --git a/cloudbuild/nightly/cloudbuild.yaml b/cloudbuild/nightly/cloudbuild.yaml
index 4e10a716..0febc831 100644
--- 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/flink-1.17-connector-bigquery/flink-connector-bigquery-table-api-examples/src/main/java/com/google/cloud/flink/bigquery/examples/BigQueryTableExample.java b/flink-1.17-connector-bigquery/flink-connector-bigquery-table-api-examples/src/main/java/com/google/cloud/flink/bigquery/examples/BigQueryTableExample.java
index 39af2e6d..d0c5c260 100644
--- a/flink-1.17-connector-bigquery/flink-connector-bigquery-table-api-examples/src/main/java/com/google/cloud/flink/bigquery/examples/BigQueryTableExample.java
+++ b/flink-1.17-connector-bigquery/flink-connector-bigquery-table-api-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>