[BEAM-6424] Avoid NPE when getWatermark() is called whereas the oldes…

…t timestamp is not yet set.
mikeymezher · Jan 23, 2019 · 967fa79 · 967fa79
1 parent 21f4b54
commit 967fa79
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sdks/java/io/rabbitmq/src/main/java/org/apache/beam/sdk/io/rabbitmq/RabbitMqIO.java b/sdks/java/io/rabbitmq/src/main/java/org/apache/beam/sdk/io/rabbitmq/RabbitMqIO.java
@@ -332,7 +332,7 @@ public boolean requiresDeduping() {
   private static class RabbitMQCheckpointMark
       implements UnboundedSource.CheckpointMark, Serializable {
     transient Channel channel;
-    Instant oldestTimestamp;
+    Instant oldestTimestamp = Instant.now();
     final List<Long> sessionIds = new ArrayList<>();
 
     @Override