diff --git a/integration-tests/__tests__/query.spec.js b/integration-tests/__tests__/query.spec.js
index daa477792..590e38ef6 100644
--- a/integration-tests/__tests__/query.spec.js
+++ b/integration-tests/__tests__/query.spec.js
@@ -53,7 +53,7 @@ function executeStreamItem(driver, conn, sql) {
 
 async function executeStream(driver, conn, sql) {
   const results = [];
-  for (const sqlItem of splitQuery(driver.getQuerySplitterOptions('stream'))) {
+  for (const sqlItem of splitQuery(sql, driver.getQuerySplitterOptions('stream'))) {
     const item = await executeStreamItem(driver, conn, sqlItem);
     results.push(...item);
   }