From 0ec4407102e0bd8b16108dee738182f23baf0c06 Mon Sep 17 00:00:00 2001
From: Jackie Han <jkhanjob@gmail.com>
Date: Thu, 1 Feb 2024 10:58:58 -0800
Subject: [PATCH] test

Signed-off-by: Jackie Han <jkhanjob@gmail.com>
---
 .../java/org/opensearch/flowframework/FlowFrameworkPlugin.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/main/java/org/opensearch/flowframework/FlowFrameworkPlugin.java b/src/main/java/org/opensearch/flowframework/FlowFrameworkPlugin.java
index 0270b6d0c..b48e05890 100644
--- 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;
     }
 }