remove child restriction

apache · Sep 15, 2017 · c5571a8 · c5571a8
1 parent 5105b72
commit c5571a8
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/...re/src/main/scala/org/apache/spark/sql/execution/datasources/TimestampTableTimeZone.scala b/...re/src/main/scala/org/apache/spark/sql/execution/datasources/TimestampTableTimeZone.scala
@@ -38,10 +38,6 @@ private[sql] case class TimestampTableTimeZone(sparkSession: SparkSession)
     // timestamp correction, to keep this idempotent.
     plan match {
       case insertIntoHadoopFs: InsertIntoHadoopFsRelationCommand =>
-        if (!insertIntoHadoopFs.query.isInstanceOf[Project]) {
-          throw new AnalysisException("Expected the child of InsertIntoHadoopFsRelationCommand " +
-            s"to be a Project in $plan")
-        }
         // The query might be reading from a parquet table which requires a different conversion;
         // this makes sure we apply the correct conversions there.
         val (fixedQuery, _) = readConversion(insertIntoHadoopFs.query)