test

Signed-off-by: Jackie Han <[email protected]>
jackiehanyang · Feb 1, 2024 · 0ec4407 · 0ec4407
1 parent b428276
commit 0ec4407
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/main/java/org/opensearch/flowframework/FlowFrameworkPlugin.java b/src/main/java/org/opensearch/flowframework/FlowFrameworkPlugin.java
@@ -115,6 +115,7 @@ public Collection<Object> createComponents(
         Supplier<RepositoriesService> repositoriesServiceSupplier
     ) {
         Settings settings = environment.settings();
+        this.client = client;
         flowFrameworkSettings = new FlowFrameworkSettings(clusterService, settings);
         MachineLearningNodeClient mlClient = new MachineLearningNodeClient(client);
         EncryptorUtils encryptorUtils = new EncryptorUtils(clusterService, client);
@@ -202,7 +203,7 @@ public List<ExecutorBuilder<?>> getExecutorBuilders(Settings settings) {
     @Override
     public Map<String, Processor.Factory<SearchResponseProcessor>> getResponseProcessors(Parameters parameters) {
         Map<String, Processor.Factory<SearchResponseProcessor>> responseProcessors = new HashMap<>();
-        responseProcessors.put(FlowFrameworkResponseProcessor.TYPE, new FlowFrameworkResponseProcessor.Factory(this.client));
+        responseProcessors.put(FlowFrameworkResponseProcessor.TYPE, new FlowFrameworkResponseProcessor.Factory(client));
         return responseProcessors;
     }
 }