diff --git a/sql/connect/client/jdbc/src/test/scala/org/apache/spark/sql/connect/client/jdbc/SparkConnectJdbcDataTypeSuite.scala b/sql/connect/client/jdbc/src/test/scala/org/apache/spark/sql/connect/client/jdbc/SparkConnectJdbcDataTypeSuite.scala index 75bd056879ef..99511c56740b 100644 --- a/sql/connect/client/jdbc/src/test/scala/org/apache/spark/sql/connect/client/jdbc/SparkConnectJdbcDataTypeSuite.scala +++ b/sql/connect/client/jdbc/src/test/scala/org/apache/spark/sql/connect/client/jdbc/SparkConnectJdbcDataTypeSuite.scala @@ -449,6 +449,11 @@ class SparkConnectJdbcDataTypeSuite extends ConnectFunSuite with RemoteSparkSess assert(bytes.length === testBytes2.length) assert(bytes.sameElements(testBytes2)) assert(!rs.wasNull) + + val stringValue = rs.getString("test_binary") + val expectedString = new String(testBytes2, java.nio.charset.StandardCharsets.UTF_8) + assert(stringValue === expectedString) + assert(!rs.next()) val metaData = rs.getMetaData