diff --git a/spark-operator/src/main/java/org/apache/spark/k8s/operator/utils/Utils.java b/spark-operator/src/main/java/org/apache/spark/k8s/operator/utils/Utils.java index 5c41ca19..36c826c8 100644 --- a/spark-operator/src/main/java/org/apache/spark/k8s/operator/utils/Utils.java +++ b/spark-operator/src/main/java/org/apache/spark/k8s/operator/utils/Utils.java @@ -96,26 +96,26 @@ public static Map sparkAppResourceLabels(final String appName) { return labels; } - public static Map driverLabels(final SparkApplication sparkApplication) { - Map labels = sparkAppResourceLabels(sparkApplication); + public static Map driverLabels(final SparkApplication app) { + Map labels = sparkAppResourceLabels(app); labels.put(Constants.LABEL_SPARK_ROLE_NAME, LABEL_SPARK_ROLE_DRIVER_VALUE); return labels; } - public static Map executorLabels(final SparkApplication sparkApplication) { - Map labels = sparkAppResourceLabels(sparkApplication); + public static Map executorLabels(final SparkApplication app) { + Map labels = sparkAppResourceLabels(app); labels.put(Constants.LABEL_SPARK_ROLE_NAME, LABEL_SPARK_ROLE_EXECUTOR_VALUE); return labels; } - public static Map sparkClusterResourceLabels(final SparkCluster master) { + public static Map sparkClusterResourceLabels(final SparkCluster cluster) { Map labels = commonManagedResourceLabels(); - labels.put(Constants.LABEL_SPARK_CLUSTER_NAME, master.getMetadata().getName()); + labels.put(Constants.LABEL_SPARK_CLUSTER_NAME, cluster.getMetadata().getName()); return labels; } - public static Map clusterLabels(final SparkCluster sparkCluster) { - Map labels = sparkClusterResourceLabels(sparkCluster); + public static Map clusterLabels(final SparkCluster cluster) { + Map labels = sparkClusterResourceLabels(cluster); labels.put(Constants.LABEL_SPARK_ROLE_NAME, LABEL_SPARK_ROLE_CLUSTER_VALUE); return labels; }