From bcba50f227871b143b21fb0dbede4edd3c671070 Mon Sep 17 00:00:00 2001 From: "Todd L. Montgomery" Date: Sun, 24 Nov 2019 10:03:06 -0800 Subject: [PATCH] [Java]: add same quickfix to dynamic join retrieval of snapshots as cluster backup. --- aeron-cluster/src/main/java/io/aeron/cluster/DynamicJoin.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/aeron-cluster/src/main/java/io/aeron/cluster/DynamicJoin.java b/aeron-cluster/src/main/java/io/aeron/cluster/DynamicJoin.java index 97c3a9ed55..15e8af983d 100644 --- a/aeron-cluster/src/main/java/io/aeron/cluster/DynamicJoin.java +++ b/aeron-cluster/src/main/java/io/aeron/cluster/DynamicJoin.java @@ -472,7 +472,7 @@ static class SnapshotReader implements ControlledFragmentHandler boolean isDone() { - return isDone && (endPosition <= recordingPosition); + return isDone && endPosition <= recordingPosition && image.isEndOfStream(); } long recordingId()