Skip to content

Commit 8b7e88a

Browse files
committed
fix
1 parent e7beb02 commit 8b7e88a

File tree

1 file changed

+1
-2
lines changed
  • sql/core/src/main/scala/org/apache/spark/sql/execution/datasources

1 file changed

+1
-2
lines changed

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

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -573,8 +573,7 @@ object DataSource extends Logging {
573573
/** Given a provider name, look up the data source class definition. */
574574
def lookupDataSource(conf: SQLConf, provider: String): Class[_] = {
575575
var provider1 = backwardCompatibilityMap.getOrElse(provider, provider)
576-
if (Seq("orc").contains(provider1.toLowerCase) && conf.getConf(SQLConf.ORC_USE_NEW_VERSION)) {
577-
logInfo(s"$provider1 is replaced with ${classOf[OrcFileFormat].getCanonicalName}")
576+
if ("orc".equalsIgnoreCase(provider1) && conf.getConf(SQLConf.ORC_USE_NEW_VERSION)) {
578577
provider1 = classOf[OrcFileFormat].getCanonicalName
579578
}
580579
val provider2 = s"$provider1.DefaultSource"

0 commit comments

Comments
 (0)