Skip to content

Commit da84f92

Browse files
committed
try 2
1 parent 9dc7163 commit da84f92

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

sql/hive-thriftserver/src/test/scala/org/apache/spark/sql/hive/thriftserver/SparkThriftServerProtocolVersionsSuite.scala

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -222,10 +222,11 @@ class SparkThriftServerProtocolVersionsSuite extends HiveThriftJdbcTest {
222222
assert(rs.next())
223223
assert(rs.getString(1) === "ABC")
224224
}
225-
testExecuteStatementWithProtocolVersion(version,
226-
"SELECT cast(cast(49960 as int) as binary)") { rs =>
225+
testExecuteStatementWithProtocolVersion(version, "SELECT cast(49960 as binary)") { rs =>
227226
assert(rs.next())
228-
assert(rs.getString(1) === UTF8String.fromBytes(NumberConverter.toBinary(49960)).toString)
227+
assertResult(Array(0, 0, 65533, 40).map(_.toChar)) {
228+
rs.getString(1).toCharArray
229+
}
229230
}
230231
testExecuteStatementWithProtocolVersion(version, "SELECT cast(null as binary)") { rs =>
231232
assert(rs.next())

0 commit comments

Comments
 (0)