diff --git a/timeseries-streaming/timeseries-java-applications/TimeSeriesPipeline/src/test/java/common/TSTestData.java b/timeseries-streaming/timeseries-java-applications/TimeSeriesPipeline/src/test/java/common/TSTestData.java
index 93c82755..53282768 100644
--- a/timeseries-streaming/timeseries-java-applications/TimeSeriesPipeline/src/test/java/common/TSTestData.java
+++ b/timeseries-streaming/timeseries-java-applications/TimeSeriesPipeline/src/test/java/common/TSTestData.java
@@ -134,6 +134,13 @@ public Builder setInputTSDataFromJSON(
                 if (advanceWatermark_expression == AdvanceWatermarkExpression.INFINITY) {
                   testStream = stream.advanceWatermarkToInfinity();
                 }
+                break;
+              case ADVANCE_PROCESSING_TIME_SECONDS:
+                stream =
+                    stream.advanceProcessingTime(
+                        Duration.standardSeconds(
+                            tsTimePointTestBuilder.getTime().getAdvanceProcessingTimeSeconds()));
+                break;
             }
           }
           tsTimePointTestBuilder.clear();
diff --git a/timeseries-streaming/timeseries-java-applications/TimeSeriesPipeline/src/test/proto/TSTest.proto b/timeseries-streaming/timeseries-java-applications/TimeSeriesPipeline/src/test/proto/TSTest.proto
index 2c7f39f7..349c1dea 100644
--- a/timeseries-streaming/timeseries-java-applications/TimeSeriesPipeline/src/test/proto/TSTest.proto
+++ b/timeseries-streaming/timeseries-java-applications/TimeSeriesPipeline/src/test/proto/TSTest.proto
@@ -30,7 +30,7 @@ message Time {
 
         int32 advance_watermark_seconds = 2;
 
-        int32 advance_processing_timeSeconds = 3;
+        int32 advance_processing_time_seconds = 3;
     }
 }