add logWarning for duplicated columns

wzhfy · wzhfy · commit 95c2d2fab6f2 · 2016-09-30T10:16:24.000-07:00
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/command/AnalyzeColumnCommand.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/command/AnalyzeColumnCommand.scala
@@ -84,6 +84,8 @@ case class AnalyzeColumnCommand(
       // do deduplication
       if (!attributesToAnalyze.contains(expr)) {
         attributesToAnalyze += expr
+      } else {
+        logWarning(s"Duplicated column: $col")
       }
     }
 

Original file line number	Diff line number	Diff line change
`@@ -84,6 +84,8 @@ case class AnalyzeColumnCommand(`
`84`	`84`	`// do deduplication`
`85`	`85`	`if (!attributesToAnalyze.contains(expr)) {`
`86`	`86`	`attributesToAnalyze += expr`
	`87`	`+ } else {`
	`88`	`+ logWarning(s"Duplicated column: $col")`
`87`	`89`	`}`
`88`	`90`	`}`
`89`	`91`