3737
3838public class MlMigrationIT extends AbstractUpgradeTestCase {
3939
40- private static final String OLD_CLUSTER_OPEN_JOB_ID = "migration-it-old-cluster-open-job" ;
41- private static final String OLD_CLUSTER_STARTED_DATAFEED_ID = "migration-it-old-cluster-started-datafeed" ;
42- private static final String OLD_CLUSTER_CLOSED_JOB_ID = "migration-it-old-cluster-closed-job" ;
43- private static final String OLD_CLUSTER_STOPPED_DATAFEED_ID = "migration-it-old-cluster-stopped-datafeed" ;
44- private static final String OLD_CLUSTER_CLOSED_JOB_EXTRA_ID = "migration-it-old-cluster-closed-job-extra" ;
45- private static final String OLD_CLUSTER_STOPPED_DATAFEED_EXTRA_ID = "migration-it-old-cluster-stopped-datafeed-extra" ;
40+ private static final String OLD_CLUSTER_OPEN_JOB_ID = "ml- migration-it-old-cluster-open-job" ;
41+ private static final String OLD_CLUSTER_STARTED_DATAFEED_ID = "ml- migration-it-old-cluster-started-datafeed" ;
42+ private static final String OLD_CLUSTER_CLOSED_JOB_ID = "ml- migration-it-old-cluster-closed-job" ;
43+ private static final String OLD_CLUSTER_STOPPED_DATAFEED_ID = "ml- migration-it-old-cluster-stopped-datafeed" ;
44+ private static final String OLD_CLUSTER_CLOSED_JOB_EXTRA_ID = "ml- migration-it-old-cluster-closed-job-extra" ;
45+ private static final String OLD_CLUSTER_STOPPED_DATAFEED_EXTRA_ID = "ml- migration-it-old-cluster-stopped-datafeed-extra" ;
4646
4747 @ Override
4848 protected Collection <String > templatesToWaitFor () {
@@ -83,7 +83,7 @@ private void waitForClusterHealth() throws IOException {
8383 }
8484
8585 private void createTestIndex () throws IOException {
86- Request createTestIndex = new Request ("PUT" , "/airline-data" );
86+ Request createTestIndex = new Request ("PUT" , "/airline-responsetime- data" );
8787 createTestIndex .setJsonEntity ("{\" mappings\" : { \" doc\" : {\" properties\" : {" +
8888 "\" time\" : {\" type\" : \" date\" }," +
8989 "\" airline\" : {\" type\" : \" keyword\" }," +
@@ -140,7 +140,7 @@ private void oldClusterTests() throws IOException {
140140 if (UPGRADED_FROM_VERSION .before (Version .V_6_6_0 )) {
141141 dfBuilder .setDelayedDataCheckConfig (null );
142142 }
143- dfBuilder .setIndices (Collections .singletonList ("airline-data" ));
143+ dfBuilder .setIndices (Collections .singletonList ("airline-responsetime- data" ));
144144 dfBuilder .setTypes (Collections .singletonList ("doc" ));
145145
146146 Request putDatafeed = new Request ("PUT" , "_xpack/ml/datafeeds/" + OLD_CLUSTER_STARTED_DATAFEED_ID );
@@ -162,7 +162,7 @@ private void oldClusterTests() throws IOException {
162162 if (UPGRADED_FROM_VERSION .before (Version .V_6_6_0 )) {
163163 stoppedDfBuilder .setDelayedDataCheckConfig (null );
164164 }
165- stoppedDfBuilder .setIndices (Collections .singletonList ("airline-data" ));
165+ stoppedDfBuilder .setIndices (Collections .singletonList ("airline-responsetime- data" ));
166166
167167 Request putStoppedDatafeed = new Request ("PUT" , "_xpack/ml/datafeeds/" + OLD_CLUSTER_STOPPED_DATAFEED_ID );
168168 putStoppedDatafeed .setJsonEntity (Strings .toString (stoppedDfBuilder .build ()));
0 commit comments