diff --git a/sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/SqlTransformRunner.java b/sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/SqlTransformRunner.java
index e8b85f63b36a..6570b7fe81b2 100644
--- a/sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/SqlTransformRunner.java
+++ b/sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/SqlTransformRunner.java
@@ -283,7 +283,8 @@ public static void runUsingSqlTransform(String[] args) throws Exception {
 
     // Make an array of pipelines, each pipeline is responsible for running a corresponding query.
     Pipeline[] pipelines = new Pipeline[queryNames.length];
-    CSVFormat csvFormat = CSVFormat.MYSQL.withDelimiter('|').withNullString("");
+    CSVFormat csvFormat =
+        CSVFormat.MYSQL.withDelimiter('|').withTrailingDelimiter().withNullString("");
 
     // Execute all queries, transform each result into a PCollection<String>, write them into
     // the txt file and store in a GCP directory.