Skip to content

Commit 637ca0e

Browse files
SPARK-19726: change the value to true in the caller side
1 parent b3b5bca commit 637ca0e

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JDBCRDD.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,7 @@ object JDBCRDD extends Logging {
6161
try {
6262
val rs = statement.executeQuery()
6363
try {
64-
JdbcUtils.getSchema(rs, dialect)
64+
JdbcUtils.getSchema(rs, dialect, true)
6565
} finally {
6666
rs.close()
6767
}

sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JdbcUtils.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -273,7 +273,7 @@ object JdbcUtils extends Logging {
273273
def getSchema(
274274
resultSet: ResultSet,
275275
dialect: JdbcDialect,
276-
alwaysNullable: Boolean = true): StructType = {
276+
alwaysNullable: Boolean = false): StructType = {
277277
val rsmd = resultSet.getMetaData
278278
val ncols = rsmd.getColumnCount
279279
val fields = new Array[StructField](ncols)

0 commit comments

Comments
 (0)