diff --git a/tests/integration/dbapi/async/V1/test_queries_async.py b/tests/integration/dbapi/async/V1/test_queries_async.py
index 26dba4b90dd..441468ceea3 100644
--- a/tests/integration/dbapi/async/V1/test_queries_async.py
+++ b/tests/integration/dbapi/async/V1/test_queries_async.py
@@ -200,7 +200,6 @@ async def test_query(c: Cursor, query: str) -> None:
     """Create table query is handled properly"""
     with connection.cursor() as c:
         # Cleanup
-        await c.execute("DROP JOIN INDEX IF EXISTS test_drop_create_async_db_join_idx")
         await c.execute(
             "DROP AGGREGATING INDEX IF EXISTS test_drop_create_async_db_agg_idx"
         )
@@ -221,13 +220,6 @@ async def test_query(c: Cursor, query: str) -> None:
             ", f float, d date, dt datetime, b bool, a array(int))",
         )
 
-        # Create join index
-        await test_query(
-            c,
-            "CREATE JOIN INDEX test_db_join_idx ON "
-            "test_drop_create_async_dim(id, sn, f)",
-        )
-
         # Create aggregating index
         await test_query(
             c,
@@ -235,9 +227,6 @@ async def test_query(c: Cursor, query: str) -> None:
             "test_drop_create_async(id, sum(f), count(dt))",
         )
 
-        # Drop join index
-        await test_query(c, "DROP JOIN INDEX test_db_join_idx")
-
         # Drop aggregating index
         await test_query(c, "DROP AGGREGATING INDEX test_db_agg_idx")
 
diff --git a/tests/integration/dbapi/async/V2/test_queries_async.py b/tests/integration/dbapi/async/V2/test_queries_async.py
index 24a85373836..f915aa30c90 100644
--- a/tests/integration/dbapi/async/V2/test_queries_async.py
+++ b/tests/integration/dbapi/async/V2/test_queries_async.py
@@ -129,7 +129,6 @@ async def test_query(c: Cursor, query: str) -> None:
     """Create table query is handled properly"""
     with connection.cursor() as c:
         # Cleanup
-        await c.execute("DROP JOIN INDEX IF EXISTS test_db_join_idx")
         await c.execute("DROP AGGREGATING INDEX IF EXISTS test_db_agg_idx")
         await c.execute("DROP TABLE IF EXISTS test_drop_create_async")
         await c.execute("DROP TABLE IF EXISTS test_drop_create_async_dim")
@@ -148,13 +147,6 @@ async def test_query(c: Cursor, query: str) -> None:
             ", f float, d date, dt datetime, b bool, a array(int))",
         )
 
-        # Create join index
-        await test_query(
-            c,
-            "CREATE JOIN INDEX test_db_join_idx ON "
-            "test_drop_create_async_dim(id, sn, f)",
-        )
-
         # Create aggregating index
         await test_query(
             c,
@@ -162,9 +154,6 @@ async def test_query(c: Cursor, query: str) -> None:
             "test_drop_create_async(id, sum(f), count(dt))",
         )
 
-        # Drop join index
-        await test_query(c, "DROP JOIN INDEX test_db_join_idx")
-
         # Drop aggregating index
         await test_query(c, "DROP AGGREGATING INDEX test_db_agg_idx")
 
diff --git a/tests/integration/dbapi/sync/V1/test_queries.py b/tests/integration/dbapi/sync/V1/test_queries.py
index 22be1209346..071eee48ff9 100644
--- a/tests/integration/dbapi/sync/V1/test_queries.py
+++ b/tests/integration/dbapi/sync/V1/test_queries.py
@@ -150,7 +150,6 @@ def test_query(c: Cursor, query: str) -> None:
     """Create table query is handled properly"""
     with connection.cursor() as c:
         # Cleanup
-        c.execute("DROP JOIN INDEX IF EXISTS test_drop_create_db_join_idx")
         c.execute("DROP AGGREGATING INDEX IF EXISTS test_drop_create_db_agg_idx")
         c.execute("DROP TABLE IF EXISTS test_drop_create_tb")
         c.execute("DROP TABLE IF EXISTS test_drop_create_tb_dim")
@@ -169,13 +168,6 @@ def test_query(c: Cursor, query: str) -> None:
             ", f float, d date, dt datetime, b bool, a array(int))",
         )
 
-        # Create join index
-        test_query(
-            c,
-            "CREATE JOIN INDEX test_drop_create_db_join_idx ON "
-            "test_drop_create_tb_dim(id, sn, f)",
-        )
-
         # Create aggregating index
         test_query(
             c,
@@ -183,9 +175,6 @@ def test_query(c: Cursor, query: str) -> None:
             "test_drop_create_tb(id, sum(f), count(dt))",
         )
 
-        # Drop join index
-        test_query(c, "DROP JOIN INDEX test_drop_create_db_join_idx")
-
         # Drop aggregating index
         test_query(c, "DROP AGGREGATING INDEX test_drop_create_db_agg_idx")
 
diff --git a/tests/integration/dbapi/sync/V2/test_queries.py b/tests/integration/dbapi/sync/V2/test_queries.py
index 68325205efc..819189588af 100644
--- a/tests/integration/dbapi/sync/V2/test_queries.py
+++ b/tests/integration/dbapi/sync/V2/test_queries.py
@@ -135,7 +135,6 @@ def test_query(c: Cursor, query: str) -> None:
     """Create table query is handled properly"""
     with connection.cursor() as c:
         # Cleanup
-        c.execute("DROP JOIN INDEX IF EXISTS test_drop_create_db_join_idx")
         c.execute("DROP AGGREGATING INDEX IF EXISTS test_drop_create_db_agg_idx")
         c.execute("DROP TABLE IF EXISTS test_drop_create_tb")
         c.execute("DROP TABLE IF EXISTS test_drop_create_tb_dim")
@@ -154,13 +153,6 @@ def test_query(c: Cursor, query: str) -> None:
             ", f float, d date, dt datetime, b bool, a array(int))",
         )
 
-        # Create join index
-        test_query(
-            c,
-            "CREATE JOIN INDEX test_drop_create_db_join_idx ON "
-            "test_drop_create_tb_dim(id, sn, f)",
-        )
-
         # Create aggregating index
         test_query(
             c,
@@ -168,9 +160,6 @@ def test_query(c: Cursor, query: str) -> None:
             "test_drop_create_tb(id, sum(f), count(dt))",
         )
 
-        # Drop join index
-        test_query(c, "DROP JOIN INDEX test_drop_create_db_join_idx")
-
         # Drop aggregating index
         test_query(c, "DROP AGGREGATING INDEX test_drop_create_db_agg_idx")