From 36f8d56d9697bccddef971e773a840b75402bb1a Mon Sep 17 00:00:00 2001 From: Niranjan Artal Date: Fri, 13 Oct 2023 09:11:40 -0700 Subject: [PATCH] update variable name --- .../spark/rapids/tool/qualification/Qualification.scala | 4 ++-- .../spark/rapids/tool/qualification/QualificationMain.scala | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/core/src/main/scala/com/nvidia/spark/rapids/tool/qualification/Qualification.scala b/core/src/main/scala/com/nvidia/spark/rapids/tool/qualification/Qualification.scala index 0fa13fddb..e733d73c2 100644 --- a/core/src/main/scala/com/nvidia/spark/rapids/tool/qualification/Qualification.scala +++ b/core/src/main/scala/com/nvidia/spark/rapids/tool/qualification/Qualification.scala @@ -35,7 +35,7 @@ class Qualification(outputDir: String, numRows: Int, hadoopConf: Configuration, pluginTypeChecker: PluginTypeChecker, reportReadSchema: Boolean, printStdout: Boolean, uiEnabled: Boolean, enablePB: Boolean, reportSqlLevel: Boolean, maxSQLDescLength: Int, mlOpsEnabled:Boolean, - ignoreTransitions: Boolean) extends Logging { + penalizeTransitions: Boolean) extends Logging { private val allApps = new ConcurrentLinkedQueue[QualificationSummaryInfo]() @@ -167,7 +167,7 @@ class Qualification(outputDir: String, numRows: Int, hadoopConf: Configuration, try { val startTime = System.currentTimeMillis() val appResult = QualificationAppInfo.createApp(path, hadoopConf, pluginTypeChecker, - reportSqlLevel, mlOpsEnabled, ignoreTransitions) + reportSqlLevel, mlOpsEnabled, penalizeTransitions) val qualAppResult = appResult match { case Left(errorMessage: String) => // Case when an error occurred during QualificationAppInfo creation diff --git a/core/src/main/scala/com/nvidia/spark/rapids/tool/qualification/QualificationMain.scala b/core/src/main/scala/com/nvidia/spark/rapids/tool/qualification/QualificationMain.scala index 3de5826b8..cb8a3c583 100644 --- a/core/src/main/scala/com/nvidia/spark/rapids/tool/qualification/QualificationMain.scala +++ b/core/src/main/scala/com/nvidia/spark/rapids/tool/qualification/QualificationMain.scala @@ -60,7 +60,7 @@ object QualificationMain extends Logging { val reportSqlLevel = appArgs.perSql.getOrElse(false) val platform = appArgs.platform.getOrElse("onprem") val mlOpsEnabled = appArgs.mlFunctions.getOrElse(false) - val ignoreTransitions = appArgs.penalizeTransitions.getOrElse(true) + val penalizeTransitions = appArgs.penalizeTransitions.getOrElse(true) val hadoopConf = RapidsToolsConfUtil.newHadoopConf @@ -94,7 +94,7 @@ object QualificationMain extends Logging { val qual = new Qualification(outputDirectory, numOutputRows, hadoopConf, timeout, nThreads, order, pluginTypeChecker, reportReadSchema, printStdout, uiEnabled, - enablePB, reportSqlLevel, maxSQLDescLength, mlOpsEnabled, ignoreTransitions) + enablePB, reportSqlLevel, maxSQLDescLength, mlOpsEnabled, penalizeTransitions) val res = qual.qualifyApps(filteredLogs) (0, res) }