Skip to content

Commit

Permalink
Fixing NodeGatewayStartedShards bwc (de)serialization issues (#4258)
Browse files Browse the repository at this point in the history
Signed-off-by: Andriy Redko <andriy.redko@aiven.io>

Signed-off-by: Andriy Redko <andriy.redko@aiven.io>
  • Loading branch information
reta authored Aug 18, 2022
1 parent d308a29 commit ee26e01
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 3 deletions.

This file was deleted.

Original file line number Diff line number Diff line change
Expand Up @@ -373,7 +373,7 @@ public NodeGatewayStartedShards(StreamInput in) throws IOException {
} else {
storeException = null;
}
if (in.getVersion().onOrAfter(Version.V_3_0_0) && in.readBoolean()) {
if (in.getVersion().onOrAfter(Version.V_2_3_0) && in.readBoolean()) {
replicationCheckpoint = new ReplicationCheckpoint(in);
} else {
replicationCheckpoint = null;
Expand Down Expand Up @@ -430,7 +430,7 @@ public void writeTo(StreamOutput out) throws IOException {
} else {
out.writeBoolean(false);
}
if (out.getVersion().onOrAfter(Version.V_3_0_0)) {
if (out.getVersion().onOrAfter(Version.V_2_3_0)) {
if (replicationCheckpoint != null) {
out.writeBoolean(true);
replicationCheckpoint.writeTo(out);
Expand Down

0 comments on commit ee26e01

Please sign in to comment.