File tree Expand file tree Collapse file tree 2 files changed +5
-2
lines changed
ml-algorithms/src/main/java/org/opensearch/ml/engine/indices
plugin/src/main/java/org/opensearch/ml/plugin Expand file tree Collapse file tree 2 files changed +5
-2
lines changed Original file line number Diff line number Diff line change 1616import java .util .Map ;
1717import java .util .concurrent .atomic .AtomicBoolean ;
1818
19+ import lombok .NonNull ;
1920import org .opensearch .OpenSearchWrapperException ;
2021import org .opensearch .ResourceAlreadyExistsException ;
2122import org .opensearch .action .admin .indices .create .CreateIndexRequest ;
4445@ RequiredArgsConstructor
4546@ Log4j2
4647public class MLIndicesHandler {
47-
48+ @ NonNull
4849 ClusterService clusterService ;
50+ @ NonNull
4951 Client client ;
52+ @ NonNull
5053 MLFeatureEnabledSetting mlFeatureEnabledSetting ;
5154 private static final Map <String , AtomicBoolean > indexMappingUpdated = new HashMap <>();
5255
Original file line number Diff line number Diff line change @@ -599,6 +599,7 @@ public Collection<Object> createComponents(
599599 Settings settings = environment .settings ();
600600 Path dataPath = environment .dataFiles ()[0 ];
601601
602+ mlFeatureEnabledSetting = new MLFeatureEnabledSetting (clusterService , settings );
602603 mlIndicesHandler = new MLIndicesHandler (clusterService , client , mlFeatureEnabledSetting );
603604
604605 SdkClient sdkClient = SdkClientFactory
@@ -665,7 +666,6 @@ public Collection<Object> createComponents(
665666 mlInputDatasetHandler = new MLInputDatasetHandler (client );
666667 modelAccessControlHelper = new ModelAccessControlHelper (clusterService , settings );
667668 connectorAccessControlHelper = new ConnectorAccessControlHelper (clusterService , settings );
668- mlFeatureEnabledSetting = new MLFeatureEnabledSetting (clusterService , settings );
669669 mlModelManager = new MLModelManager (
670670 clusterService ,
671671 scriptService ,
You can’t perform that action at this time.
0 commit comments