diff --git a/common/unsafe/src/main/java/org/apache/spark/sql/catalyst/util/CollationSupport.java b/common/unsafe/src/main/java/org/apache/spark/sql/catalyst/util/CollationSupport.java index fa4a40b74ab24..450a3eea1a3a0 100644 --- a/common/unsafe/src/main/java/org/apache/spark/sql/catalyst/util/CollationSupport.java +++ b/common/unsafe/src/main/java/org/apache/spark/sql/catalyst/util/CollationSupport.java @@ -332,7 +332,7 @@ public static String genCode(final String word, final String set, final int coll if (collation.supportsBinaryEquality) { return String.format(expr + "Binary(%s, %s)", word, set); } else { - return String.format(expr + "execCollationAware(%s, %s, %d)", word, set, collationId); + return String.format(expr + "CollationAware(%s, %s, %d)", word, set, collationId); } } public static int execBinary(final UTF8String word, final UTF8String set) {