Skip to content

Commit 1dbcd0c

Browse files
committed
fix type check
1 parent f9a1ecf commit 1dbcd0c

File tree

2 files changed

+4
-1
lines changed

2 files changed

+4
-1
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/collectionOperations.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -39,6 +39,7 @@ trait BinaryArrayExpressionWithImplicitCast extends BinaryExpression
3939
override def inputTypes: Seq[AbstractDataType] = {
4040
TypeCoercion.findWiderTypeForTwo(left.dataType, right.dataType) match {
4141
case Some(arrayType) => Seq(arrayType, arrayType)
42+
case None => Seq.empty
4243
}
4344
}
4445

sql/core/src/test/scala/org/apache/spark/sql/DataFrameFunctionsSuite.scala

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -425,8 +425,10 @@ class DataFrameFunctionsSuite extends QueryTest with SharedSQLContext {
425425
checkAnswer(df.select(arrays_overlap(df("a"), df("b"))), answer)
426426
checkAnswer(df.selectExpr("arrays_overlap(a, b)"), answer)
427427

428+
checkAnswer(sql("select arrays_overlap(array(1, 2, 3), array('a', 'b', 'c'))"), Row(false))
429+
428430
intercept[AnalysisException] {
429-
df.selectExpr("arrays_overlap(array(1, 2, 3), array('a', 'b', 'c'))")
431+
sql("select arrays_overlap(array(array(1)), array('a'))")
430432
}
431433
}
432434

0 commit comments

Comments
 (0)