fix df

adrian-wang · adrian-wang · commit afb60a59fba1 · 2016-01-20T18:48:13.000-08:00
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala b/sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala
@@ -474,6 +474,7 @@ class DataFrame private[sql](
           val rightCol = withPlan(joined.right).resolve(col).toAttribute.withNullability(true)
           Alias(Coalesce(Seq(leftCol, rightCol)), col)()
         }
+      case NaturalJoin(_) => sys.error("NaturalJoin with using clause is not supported.")
     }
     // The nullability of output of joined could be different than original column,
     // so we can only compare them by exprId

Original file line number	Diff line number	Diff line change
`@@ -474,6 +474,7 @@ class DataFrame private[sql](`
`474`	`474`	`val rightCol = withPlan(joined.right).resolve(col).toAttribute.withNullability(true)`
`475`	`475`	`Alias(Coalesce(Seq(leftCol, rightCol)), col)()`
`476`	`476`	`}`
	`477`	`+ case NaturalJoin(_) => sys.error("NaturalJoin with using clause is not supported.")`
`477`	`478`	`}`
`478`	`479`	`// The nullability of output of joined could be different than original column,`
`479`	`480`	`// so we can only compare them by exprId`