diff --git a/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorkerTest.java b/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorkerTest.java index 12b7df20c538..17b59ecf3737 100644 --- a/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorkerTest.java +++ b/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorkerTest.java @@ -794,7 +794,8 @@ public void testHotKeyLogging() throws Exception { final int numIters = 2000; for (int i = 0; i < numIters; ++i) { - server.addWorkToOffer(makeInput(i, 0, "key", DEFAULT_SHARDING_KEY)); + server.addWorkToOffer( + makeInput(i, TimeUnit.MILLISECONDS.toMicros(i), "key", DEFAULT_SHARDING_KEY)); } Map result = server.waitForAndGetCommits(numIters); @@ -829,7 +830,8 @@ public void testHotKeyLoggingNotEnabled() throws Exception { final int numIters = 2000; for (int i = 0; i < numIters; ++i) { - server.addWorkToOffer(makeInput(i, 0, "key", DEFAULT_SHARDING_KEY)); + server.addWorkToOffer( + makeInput(i, TimeUnit.MILLISECONDS.toMicros(i), "key", DEFAULT_SHARDING_KEY)); } Map result = server.waitForAndGetCommits(numIters);