Merge branch 'refs/heads/fix-post-release-nightly-snap' into fix-mobi…

…le-gaming-java

# Conflicts:
#	release/src/main/groovy/mobilegaming-java-dataflow.groovy
#	release/src/main/groovy/mobilegaming-java-direct.groovy

.github/workflows/beam_PostRelease_NightlySnapshot.yml

@@ -26,7 +26,7 @@ on:
         description: Location of the staged artifacts in Maven central (https://repository.apache.org/content/repositories/orgapachebeam-NNNN/).
         required: true
   schedule:
-    - cron: '15 16 * * *'
+    - cron: '15 */2 * * *'
 
 #Setting explicit permissions for the action to avoid the default permissions which are `write-all` in case of pull_request_target event
 permissions:

examples/java/src/main/java/org/apache/beam/examples/complete/game/utils/WriteToBigQuery.java

@@ -28,6 +28,7 @@
 import org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO;
 import org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.Write.CreateDisposition;
 import org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.Write.WriteDisposition;
+import org.apache.beam.sdk.io.gcp.bigquery.InsertRetryPolicy;
 import org.apache.beam.sdk.transforms.DoFn;
 import org.apache.beam.sdk.transforms.PTransform;
 import org.apache.beam.sdk.transforms.ParDo;
@@ -129,7 +130,8 @@ public PDone expand(PCollection<InputT> teamAndScore) {
                 .to(getTable(projectId, datasetId, tableName))
                 .withSchema(getSchema())
                 .withCreateDisposition(CreateDisposition.CREATE_IF_NEEDED)
-                .withWriteDisposition(WriteDisposition.WRITE_APPEND));
+                .withWriteDisposition(WriteDisposition.WRITE_APPEND)
+                .withFailedInsertRetryPolicy(InsertRetryPolicy.retryTransientErrors()));
     return PDone.in(teamAndScore.getPipeline());
   }