Skip to content

Commit

Permalink
Update versions for start_trial after backport (#30218)
Browse files Browse the repository at this point in the history
This commit is a follow up to #30135. It updates the stream
compatibility versions in the start_trial requests and responses to
reflect that fact that this work has been backported to 6.3.
  • Loading branch information
Tim-Brooks authored May 2, 2018
1 parent 3aec8c7 commit 226b45e
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -55,8 +55,7 @@ public void readFrom(StreamInput in) throws IOException {

@Override
public void writeTo(StreamOutput out) throws IOException {
// TODO: Change to 6.3 after backport
Version version = Version.V_7_0_0_alpha1;
Version version = Version.V_6_3_0;
if (out.getVersion().onOrAfter(version)) {
super.writeTo(out);
out.writeString(type);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -76,8 +76,7 @@ public Status getStatus() {
@Override
public void readFrom(StreamInput in) throws IOException {
status = in.readEnum(Status.class);
// TODO: Change to 6.3 after backport
if (in.getVersion().onOrAfter(Version.V_7_0_0_alpha1)) {
if (in.getVersion().onOrAfter(Version.V_6_3_0)) {
acknowledgeMessage = in.readOptionalString();
int size = in.readVInt();
Map<String, String[]> acknowledgeMessages = new HashMap<>(size);
Expand All @@ -98,8 +97,7 @@ public void readFrom(StreamInput in) throws IOException {

@Override
public void writeTo(StreamOutput out) throws IOException {
// TODO: Change to 6.3 after backport
Version version = Version.V_7_0_0_alpha1;
Version version = Version.V_6_3_0;
if (out.getVersion().onOrAfter(version)) {
out.writeEnum(status);
out.writeOptionalString(acknowledgeMessage);
Expand Down

0 comments on commit 226b45e

Please sign in to comment.