fix test

snowflakedb · Jul 29, 2024 · bbb34d4 · bbb34d4
1 parent e8a4dca
commit bbb34d4
Showing 1 changed file with 0 additions and 3 deletions.
diff --git a/src/it/scala/net/snowflake/spark/snowflake/SnowflakeResultSetRDDSuite.scala b/src/it/scala/net/snowflake/spark/snowflake/SnowflakeResultSetRDDSuite.scala
@@ -1012,7 +1012,6 @@ class SnowflakeResultSetRDDSuite extends IntegrationSuiteBase {
   test("testReadWriteSomePartitionsEmpty") {
     setupLargeResultTable
     if (!skipBigDataTest) {
-      SnowflakeConnectorUtils.disablePushdownSession(sparkSession)
       val originalDF = sparkSession
         .sql(s"select * from test_table_large_result")
 
@@ -1048,8 +1047,6 @@ class SnowflakeResultSetRDDSuite extends IntegrationSuiteBase {
 
       resultSet = readBackDF.collect()
       assert(resultSet.length == sourceLength)
-
-      SnowflakeConnectorUtils.enablePushdownSession(sparkSession)
     }
   }