From 9dc7163759368fe173a7381e6b227f0a3e391864 Mon Sep 17 00:00:00 2001 From: Yuming Wang Date: Sat, 17 Aug 2019 07:51:50 +0800 Subject: [PATCH 1/2] try 1 --- .../thriftserver/SparkThriftServerProtocolVersionsSuite.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/sql/hive-thriftserver/src/test/scala/org/apache/spark/sql/hive/thriftserver/SparkThriftServerProtocolVersionsSuite.scala b/sql/hive-thriftserver/src/test/scala/org/apache/spark/sql/hive/thriftserver/SparkThriftServerProtocolVersionsSuite.scala index f198372a4c998..8af4ba44691bf 100644 --- a/sql/hive-thriftserver/src/test/scala/org/apache/spark/sql/hive/thriftserver/SparkThriftServerProtocolVersionsSuite.scala +++ b/sql/hive-thriftserver/src/test/scala/org/apache/spark/sql/hive/thriftserver/SparkThriftServerProtocolVersionsSuite.scala @@ -222,7 +222,8 @@ class SparkThriftServerProtocolVersionsSuite extends HiveThriftJdbcTest { assert(rs.next()) assert(rs.getString(1) === "ABC") } - testExecuteStatementWithProtocolVersion(version, "SELECT cast(49960 as binary)") { rs => + testExecuteStatementWithProtocolVersion(version, + "SELECT cast(cast(49960 as int) as binary)") { rs => assert(rs.next()) assert(rs.getString(1) === UTF8String.fromBytes(NumberConverter.toBinary(49960)).toString) } From da84f92f7eb011184641eefb81f669bcdf74d080 Mon Sep 17 00:00:00 2001 From: Yuming Wang Date: Sat, 17 Aug 2019 12:02:18 +0800 Subject: [PATCH 2/2] try 2 --- .../SparkThriftServerProtocolVersionsSuite.scala | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/sql/hive-thriftserver/src/test/scala/org/apache/spark/sql/hive/thriftserver/SparkThriftServerProtocolVersionsSuite.scala b/sql/hive-thriftserver/src/test/scala/org/apache/spark/sql/hive/thriftserver/SparkThriftServerProtocolVersionsSuite.scala index 8af4ba44691bf..a150c33110855 100644 --- a/sql/hive-thriftserver/src/test/scala/org/apache/spark/sql/hive/thriftserver/SparkThriftServerProtocolVersionsSuite.scala +++ b/sql/hive-thriftserver/src/test/scala/org/apache/spark/sql/hive/thriftserver/SparkThriftServerProtocolVersionsSuite.scala @@ -222,10 +222,11 @@ class SparkThriftServerProtocolVersionsSuite extends HiveThriftJdbcTest { assert(rs.next()) assert(rs.getString(1) === "ABC") } - testExecuteStatementWithProtocolVersion(version, - "SELECT cast(cast(49960 as int) as binary)") { rs => + testExecuteStatementWithProtocolVersion(version, "SELECT cast(49960 as binary)") { rs => assert(rs.next()) - assert(rs.getString(1) === UTF8String.fromBytes(NumberConverter.toBinary(49960)).toString) + assertResult(Array(0, 0, 65533, 40).map(_.toChar)) { + rs.getString(1).toCharArray + } } testExecuteStatementWithProtocolVersion(version, "SELECT cast(null as binary)") { rs => assert(rs.next())