File tree Expand file tree Collapse file tree 3 files changed +4
-6
lines changed
main/java/org/elasticsearch/persistent
test/java/org/elasticsearch/cluster Expand file tree Collapse file tree 3 files changed +4
-6
lines changed Original file line number Diff line number Diff line change @@ -313,7 +313,7 @@ public PersistentTask(StreamInput in) throws IOException {
313
313
id = in .readString ();
314
314
allocationId = in .readLong ();
315
315
taskName = in .readString ();
316
- if (in .getVersion ().onOrAfter (Version .V_7_0_0_alpha1 )) {
316
+ if (in .getVersion ().onOrAfter (Version .V_6_4_0 )) {
317
317
params = (P ) in .readNamedWriteable (PersistentTaskParams .class );
318
318
} else {
319
319
params = (P ) in .readOptionalNamedWriteable (PersistentTaskParams .class );
@@ -328,7 +328,7 @@ public void writeTo(StreamOutput out) throws IOException {
328
328
out .writeString (id );
329
329
out .writeLong (allocationId );
330
330
out .writeString (taskName );
331
- if (out .getVersion ().onOrAfter (Version .V_7_0_0_alpha1 )) {
331
+ if (out .getVersion ().onOrAfter (Version .V_6_4_0 )) {
332
332
out .writeNamedWriteable (params );
333
333
} else {
334
334
out .writeOptionalNamedWriteable (params );
Original file line number Diff line number Diff line change @@ -93,7 +93,7 @@ public void readFrom(StreamInput in) throws IOException {
93
93
super .readFrom (in );
94
94
taskId = in .readString ();
95
95
taskName = in .readString ();
96
- if (in .getVersion ().onOrAfter (Version .V_7_0_0_alpha1 )) {
96
+ if (in .getVersion ().onOrAfter (Version .V_6_4_0 )) {
97
97
params = in .readNamedWriteable (PersistentTaskParams .class );
98
98
} else {
99
99
params = in .readOptionalNamedWriteable (PersistentTaskParams .class );
@@ -105,7 +105,7 @@ public void writeTo(StreamOutput out) throws IOException {
105
105
super .writeTo (out );
106
106
out .writeString (taskId );
107
107
out .writeString (taskName );
108
- if (out .getVersion ().onOrAfter (Version .V_7_0_0_alpha1 )) {
108
+ if (out .getVersion ().onOrAfter (Version .V_6_4_0 )) {
109
109
out .writeNamedWriteable (params );
110
110
} else {
111
111
out .writeOptionalNamedWriteable (params );
Original file line number Diff line number Diff line change 33
33
import org .elasticsearch .common .io .stream .StreamInput ;
34
34
import org .elasticsearch .common .io .stream .StreamOutput ;
35
35
import org .elasticsearch .common .io .stream .Writeable ;
36
- import org .elasticsearch .common .settings .Settings ;
37
36
import org .elasticsearch .common .xcontent .NamedXContentRegistry ;
38
37
import org .elasticsearch .common .xcontent .XContentBuilder ;
39
38
import org .elasticsearch .common .xcontent .XContentParser ;
43
42
import org .elasticsearch .script .ScriptService ;
44
43
import org .elasticsearch .test .ESIntegTestCase ;
45
44
import org .elasticsearch .threadpool .ThreadPool ;
46
- import org .elasticsearch .transport .TcpTransport ;
47
45
import org .elasticsearch .watcher .ResourceWatcherService ;
48
46
49
47
import java .io .IOException ;
You can’t perform that action at this time.
0 commit comments