diff --git a/async-query-core/src/test/java/org/opensearch/sql/spark/asyncquery/AsyncQueryCoreIntegTest.java b/async-query-core/src/test/java/org/opensearch/sql/spark/asyncquery/AsyncQueryCoreIntegTest.java
index db6080fbdc..f2d205ffc6 100644
--- a/async-query-core/src/test/java/org/opensearch/sql/spark/asyncquery/AsyncQueryCoreIntegTest.java
+++ b/async-query-core/src/test/java/org/opensearch/sql/spark/asyncquery/AsyncQueryCoreIntegTest.java
@@ -133,7 +133,7 @@ public class AsyncQueryCoreIntegTest {
   @BeforeEach
   public void setUp() {
     emrServerlessClientFactory =
-        () -> new EmrServerlessClientImpl(awsemrServerless, metricsService);
+        (accountId) -> new EmrServerlessClientImpl(awsemrServerless, metricsService);
     SessionManager sessionManager =
         new SessionManager(
             sessionStorageService,