From c62581a0de50226590bd82185c8d3959fdc812a0 Mon Sep 17 00:00:00 2001
From: Andrew Crites <andrew.crites@gmail.com>
Date: Thu, 25 Sep 2025 16:06:30 -0700
Subject: [PATCH] Update DetectNewPartitionsAction.java

Adds additional logging about creation time and output timestamp for changestream partitions.
---
 .../changestreams/action/DetectNewPartitionsAction.java     | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/action/DetectNewPartitionsAction.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/action/DetectNewPartitionsAction.java
index 080372d04593..ed1390af3ab7 100644
--- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/action/DetectNewPartitionsAction.java
+++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/action/DetectNewPartitionsAction.java
@@ -190,11 +190,13 @@ private void outputBatch(
           partition.toBuilder().setScheduledAt(scheduledAt).build();
 
       LOG.info(
-          "[{}] Outputting partition at {} with start time {} and end time {}",
+          "[{}] Outputting partition at {} with start time {}, end time {}, creation time {} and output timestamp {}",
           updatedPartition.getPartitionToken(),
           updatedPartition.getScheduledAt(),
           updatedPartition.getStartTimestamp(),
-          updatedPartition.getEndTimestamp());
+          updatedPartition.getEndTimestamp()
+          createdAt,
+          minWatermark);
 
       receiver.outputWithTimestamp(partition, new Instant(minWatermark.toSqlTimestamp()));