simply test

cloud-fan · cloud-fan · commit 6a100808e503 · 2015-11-18T08:49:49.000+08:00
diff --git a/docker-integration-tests/src/test/scala/org/apache/spark/sql/jdbc/PostgresIntegrationSuite.scala b/docker-integration-tests/src/test/scala/org/apache/spark/sql/jdbc/PostgresIntegrationSuite.scala
@@ -88,7 +88,7 @@ class PostgresIntegrationSuite extends DockerJDBCIntegrationSuite {
     df.write.jdbc(jdbcUrl, "public.barcopy", new Properties)
     // Test write null values.
     df.select(df.queryExecution.analyzed.output.map { a =>
-      Column(If(Literal(true), Literal(null), a)).as(a.name)
+      Column(Literal.create(null, a.dataType)).as(a.name)
     }: _*).write.jdbc(jdbcUrl, "public.barcopy2", new Properties)
   }
 }

Original file line number	Diff line number	Diff line change
`@@ -88,7 +88,7 @@ class PostgresIntegrationSuite extends DockerJDBCIntegrationSuite {`
`88`	`88`	`df.write.jdbc(jdbcUrl, "public.barcopy", new Properties)`
`89`	`89`	`// Test write null values.`
`90`	`90`	`df.select(df.queryExecution.analyzed.output.map { a =>`
`91`		`- Column(If(Literal(true), Literal(null), a)).as(a.name)`
	`91`	`+ Column(Literal.create(null, a.dataType)).as(a.name)`
`92`	`92`	`}: _*).write.jdbc(jdbcUrl, "public.barcopy2", new Properties)`
`93`	`93`	`}`
`94`	`94`	`}`