Skip to content

Commit 4194a62

Browse files
authored
Adds logging to DetectNewPartitionsAction in spanner changestream source. (#36290)
1 parent ac6d033 commit 4194a62

1 file changed

Lines changed: 4 additions & 2 deletions

File tree

sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/action/DetectNewPartitionsAction.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -190,11 +190,13 @@ private void outputBatch(
190190
partition.toBuilder().setScheduledAt(scheduledAt).build();
191191

192192
LOG.info(
193-
"[{}] Outputting partition at {} with start time {} and end time {}",
193+
"[{}] Outputting partition at {} with start time {}, end time {}, creation time {} and output timestamp {}",
194194
updatedPartition.getPartitionToken(),
195195
updatedPartition.getScheduledAt(),
196196
updatedPartition.getStartTimestamp(),
197-
updatedPartition.getEndTimestamp());
197+
updatedPartition.getEndTimestamp(),
198+
createdAt,
199+
minWatermark);
198200

199201
receiver.outputWithTimestamp(partition, new Instant(minWatermark.toSqlTimestamp()));
200202

0 commit comments

Comments
 (0)