Github user dongjoon-hyun commented on a diff in the pull request:
https://github.com/apache/spark/pull/20610#discussion_r168354972
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/streaming/FileStreamSourceSuite.scala
---
@@ -207,6 +207,16 @@ class FileStreamSourceSuite extends
FileStreamSourceTest {
.collect { case s @ StreamingRelation(dataSource, _, _) => s.schema
}.head
}
+ override def beforeAll(): Unit = {
+ super.beforeAll()
+ spark.sessionState.conf.setConf(SQLConf.ORC_IMPLEMENTATION, "native")
+ }
+
+ override def afterAll(): Unit = {
+ spark.sessionState.conf.unsetConf(SQLConf.ORC_IMPLEMENTATION)
+ super.afterAll()
--- End diff --
Thanks. Yep. It's done.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
