address comment

apache · Nov 8, 2023 · 6049a29 · 6049a29
1 parent f699aef
commit 6049a29
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/common/src/main/scala/org/apache/celeborn/common/util/CelebornHadoopUtils.scala b/common/src/main/scala/org/apache/celeborn/common/util/CelebornHadoopUtils.scala
@@ -80,7 +80,7 @@ object CelebornHadoopUtils extends Logging {
     // If we are accessing HDFS and it has Kerberos enabled, we have to login
     // from a keytab file so that we can access HDFS beyond the kerberos ticket expiration.
     UserGroupInformation.setConfiguration(hadoopConf)
-    if ("kerberos" == hadoopConf.get("hadoop.security.authentication")) {
+    if ("kerberos".equals(hadoopConf.get("hadoop.security.authentication").toLowerCase)) {
       val principal = conf.hdfsStorageKerberosPrincipal
         .getOrElse(throw new NoSuchElementException(
           CelebornConf.HDFS_STORAGE_KERBEROS_PRINCIPAL.key))