Fixes a minor deprecation warning (#4223)

Signed-off-by: Chong Gao <[email protected]>
NVIDIA · Nov 29, 2021 · cd725b8 · cd725b8
1 parent f2c9176
commit cd725b8
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/...c/main/scala/org/apache/spark/sql/execution/datasources/rapids/GpuPartitioningUtils.scala b/...c/main/scala/org/apache/spark/sql/execution/datasources/rapids/GpuPartitioningUtils.scala
@@ -109,9 +109,6 @@ object GpuPartitioningUtils {
    *
    * mainly copied from PartitioningAwareFileIndex.basePaths
    */
-  @scala.annotation.nowarn(
-    "msg=method isDirectory in class FileSystem is deprecated"
-  )
   private def getBasePaths(
     hadoopConf: Configuration,
     basePathOption: Option[Path],
@@ -121,7 +118,7 @@ object GpuPartitioningUtils {
     basePathOption match {
       case Some(userDefinedBasePath) =>
         val fs = userDefinedBasePath.getFileSystem(hadoopConf)
-        if (!fs.isDirectory(userDefinedBasePath)) {
+        if (!fs.getFileStatus(userDefinedBasePath).isDirectory) {
           throw new IllegalArgumentException(s"Option '$BASE_PATH_PARAM' must be a directory")
         }
         val qualifiedBasePath = fs.makeQualified(userDefinedBasePath)