From feaf32b732e530abf71ffa532278143df2ca5a79 Mon Sep 17 00:00:00 2001 From: Amrane Ait Zeouay Date: Wed, 5 Apr 2023 17:01:59 +0200 Subject: [PATCH] [#25887] fix(JmsIO): replace google timestamp with java instant #25887 Fixes #25887 Co-Authored-By: Amrane Ait Zeouay <122456352+amranezeRenault@users.noreply.github.com> --- .../jms/src/test/java/org/apache/beam/sdk/io/jms/JmsIOIT.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/sdks/java/io/jms/src/test/java/org/apache/beam/sdk/io/jms/JmsIOIT.java b/sdks/java/io/jms/src/test/java/org/apache/beam/sdk/io/jms/JmsIOIT.java index 4c81cff94c555..d7cd01f815861 100644 --- a/sdks/java/io/jms/src/test/java/org/apache/beam/sdk/io/jms/JmsIOIT.java +++ b/sdks/java/io/jms/src/test/java/org/apache/beam/sdk/io/jms/JmsIOIT.java @@ -23,9 +23,9 @@ import static org.junit.Assert.assertNotEquals; import static org.junit.Assert.assertTrue; -import com.google.cloud.Timestamp; import java.io.IOException; import java.io.Serializable; +import java.time.Instant; import java.util.Arrays; import java.util.Collection; import java.util.HashSet; @@ -243,7 +243,7 @@ private PipelineResult publishingMessages() { private void collectAndPublishMetrics(PipelineResult writeResult, PipelineResult readResult) { String uuid = UUID.randomUUID().toString(); - String timestamp = Timestamp.now().toString(); + String timestamp = Instant.now().toString(); Set> readSuppliers = getMetricsSuppliers(uuid, timestamp, READ_TIME_METRIC);