From bbb34d45afc1355fb2fd5477ce57fcc5eea2d844 Mon Sep 17 00:00:00 2001 From: Bing Li Date: Mon, 29 Jul 2024 15:27:20 -0700 Subject: [PATCH] fix test --- .../snowflake/spark/snowflake/SnowflakeResultSetRDDSuite.scala | 3 --- 1 file changed, 3 deletions(-) diff --git a/src/it/scala/net/snowflake/spark/snowflake/SnowflakeResultSetRDDSuite.scala b/src/it/scala/net/snowflake/spark/snowflake/SnowflakeResultSetRDDSuite.scala index 0e64bac0..236b8fbd 100644 --- 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) } }