diff --git a/examples/java/src/main/java/org/apache/beam/examples/cookbook/TriggerExample.java b/examples/java/src/main/java/org/apache/beam/examples/cookbook/TriggerExample.java
index cd3c6dd84157..64a4f4d73d32 100644
--- a/examples/java/src/main/java/org/apache/beam/examples/cookbook/TriggerExample.java
+++ b/examples/java/src/main/java/org/apache/beam/examples/cookbook/TriggerExample.java
@@ -486,7 +486,10 @@ static void runTriggerExample(TrafficFlowOptions options) throws IOException {
           .get(i)
           .apply(
               "BigQuery Write Rows" + i,
-              BigQueryIO.writeTableRows().to(tableRef).withSchema(getSchema()));
+              BigQueryIO.writeTableRows()
+                  .to(tableRef)
+                  .withSchema(getSchema())
+                  .withWriteDisposition(BigQueryIO.Write.WriteDisposition.WRITE_APPEND));
     }
 
     PipelineResult result = pipeline.run();