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.
- * The sequence of operations in both pipelines is: source > flatMap > sink
* Flink command line format is:
* flink run {additional runtime params} {path to this jar}/BigQueryTableExample.jar *
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. - 0.4-SNAPSHOT + 0.5-SNAPSHOT 1.17.1 32.1.3-jre 26.33.0