Make InsertIntoTable happy.

yhuai · yhuai · commit 9a266114fca9 · 2015-02-27T20:13:06.000-08:00
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicOperators.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicOperators.scala
@@ -120,7 +120,8 @@ case class InsertIntoTable(
   override def output = child.output
 
   override lazy val resolved = childrenResolved && child.output.zip(table.output).forall {
-    case (childAttr, tableAttr) => childAttr.dataType == tableAttr.dataType
+    case (childAttr, tableAttr) =>
+      DataType.equalsIgnoreCompatibleNullability(childAttr.dataType, tableAttr.dataType)
   }
 }
 

Original file line number	Diff line number	Diff line change
`@@ -120,7 +120,8 @@ case class InsertIntoTable(`
`120`	`120`	`override def output = child.output`
`121`	`121`
`122`	`122`	`override lazy val resolved = childrenResolved && child.output.zip(table.output).forall {`
`123`		`- case (childAttr, tableAttr) => childAttr.dataType == tableAttr.dataType`
	`123`	`+ case (childAttr, tableAttr) =>`
	`124`	`+ DataType.equalsIgnoreCompatibleNullability(childAttr.dataType, tableAttr.dataType)`
`124`	`125`	`}`
`125`	`126`	`}`
`126`	`127`