Skip to content

Commit feaf32b

Browse files
[#25887] fix(JmsIO): replace google timestamp with java instant #25887
Fixes #25887 Co-Authored-By: Amrane Ait Zeouay <122456352+amranezeRenault@users.noreply.github.com>
1 parent eae4611 commit feaf32b

File tree

1 file changed

+2
-2
lines changed
  • sdks/java/io/jms/src/test/java/org/apache/beam/sdk/io/jms

1 file changed

+2
-2
lines changed

sdks/java/io/jms/src/test/java/org/apache/beam/sdk/io/jms/JmsIOIT.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,9 +23,9 @@
2323
import static org.junit.Assert.assertNotEquals;
2424
import static org.junit.Assert.assertTrue;
2525

26-
import com.google.cloud.Timestamp;
2726
import java.io.IOException;
2827
import java.io.Serializable;
28+
import java.time.Instant;
2929
import java.util.Arrays;
3030
import java.util.Collection;
3131
import java.util.HashSet;
@@ -243,7 +243,7 @@ private PipelineResult publishingMessages() {
243243

244244
private void collectAndPublishMetrics(PipelineResult writeResult, PipelineResult readResult) {
245245
String uuid = UUID.randomUUID().toString();
246-
String timestamp = Timestamp.now().toString();
246+
String timestamp = Instant.now().toString();
247247

248248
Set<Function<MetricsReader, NamedTestResult>> readSuppliers =
249249
getMetricsSuppliers(uuid, timestamp, READ_TIME_METRIC);

0 commit comments

Comments
 (0)