Commit eeb2f39 1 parent c85ee68 commit eeb2f39 Copy full SHA for eeb2f39
File tree 2 files changed +7
-4
lines changed
server/src/internalClusterTest/java/org/opensearch/remotemigration
test/framework/src/main/java/org/opensearch/test
2 files changed +7
-4
lines changed Original file line number Diff line number Diff line change 12
12
import org .opensearch .common .settings .Settings ;
13
13
import org .opensearch .common .settings .SettingsException ;
14
14
import org .opensearch .common .unit .TimeValue ;
15
+ import org .opensearch .repositories .blobstore .BlobStoreRepository ;
15
16
import org .opensearch .test .InternalTestCluster ;
16
17
import org .opensearch .test .OpenSearchIntegTestCase ;
17
18
@@ -68,15 +69,17 @@ public void testNewIndexIsRemoteStoreBackedForRemoteStoreDirectionAndMixedMode()
68
69
assertRemoteStoreBackedIndex (indexName2 );
69
70
}
70
71
71
- @ AwaitsFix (bugUrl = "https://github.com/opensearch-project/OpenSearch/issues/15793" )
72
72
public void testNewRestoredIndexIsRemoteStoreBackedForRemoteStoreDirectionAndMixedMode () throws Exception {
73
73
logger .info ("Initialize cluster: gives non remote cluster manager" );
74
74
initializeCluster (false );
75
75
76
76
logger .info ("Add remote and non-remote nodes" );
77
77
setClusterMode (MIXED .mode );
78
78
addRemote = false ;
79
- String nonRemoteNodeName = internalCluster ().startNode ();
79
+ Settings settings = Settings .builder ()
80
+ .put (BlobStoreRepository .SNAPSHOT_SHARD_PATH_PREFIX_SETTING .getKey (), snapshotShardPathFixedPrefix ? "c" : "" )
81
+ .build ();
82
+ String nonRemoteNodeName = internalCluster ().startNode (settings );
80
83
addRemote = true ;
81
84
String remoteNodeName = internalCluster ().startNode ();
82
85
internalCluster ().validateClusterFormed ();
Original file line number Diff line number Diff line change @@ -403,7 +403,7 @@ public abstract class OpenSearchIntegTestCase extends OpenSearchTestCase {
403
403
404
404
private static Boolean segmentsPathFixedPrefix ;
405
405
406
- private static Boolean snapshotShardPathFixedPrefix ;
406
+ protected static Boolean snapshotShardPathFixedPrefix ;
407
407
408
408
private Path remoteStoreRepositoryPath ;
409
409
@@ -2904,7 +2904,7 @@ private static Settings buildRemoteStoreNodeAttributes(
2904
2904
settings .put (RemoteStoreSettings .CLUSTER_REMOTE_STORE_PINNED_TIMESTAMP_ENABLED .getKey (), randomBoolean ());
2905
2905
settings .put (RemoteStoreSettings .CLUSTER_REMOTE_STORE_SEGMENTS_PATH_PREFIX .getKey (), translogPathFixedPrefix ? "a" : "" );
2906
2906
settings .put (RemoteStoreSettings .CLUSTER_REMOTE_STORE_TRANSLOG_PATH_PREFIX .getKey (), segmentsPathFixedPrefix ? "b" : "" );
2907
- settings .put (BlobStoreRepository .SNAPSHOT_SHARD_PATH_PREFIX_SETTING .getKey (), segmentsPathFixedPrefix ? "c" : "" );
2907
+ settings .put (BlobStoreRepository .SNAPSHOT_SHARD_PATH_PREFIX_SETTING .getKey (), snapshotShardPathFixedPrefix ? "c" : "" );
2908
2908
return settings .build ();
2909
2909
}
2910
2910
You can’t perform that action at this time.
0 commit comments