Details
-
Bug
-
Status: Resolved
-
Blocker
-
Resolution: Fixed
-
1.5.0
-
None
Description
Exchange needs to check whether unsafe mode is enabled in its tungstenMode method:
override def nodeName: String = if (tungstenMode) "TungstenExchange" else "Exchange" /** * Returns true iff we can support the data type, and we are not doing range partitioning. */ private lazy val tungstenMode: Boolean = { GenerateUnsafeProjection.canSupport(child.schema) && !newPartitioning.isInstanceOf[RangePartitioning] }