Skip to content

Commit 48d9e48

Browse files
committed
Update based on review comments
1 parent b6a4ee9 commit 48d9e48

File tree

1 file changed

+7
-3
lines changed

1 file changed

+7
-3
lines changed

PluginsAndFeatures/azure-toolkit-for-intellij/src/com/microsoft/azure/sparkserverless/SparkServerlessClusterOpsCtrl.java

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,7 @@
2525
import com.intellij.openapi.diagnostic.Logger;
2626
import com.microsoft.azure.hdinsight.common.logger.ILogger;
2727
import com.microsoft.azure.hdinsight.common.mvc.IdeSchedulers;
28+
import com.microsoft.azure.hdinsight.sdk.common.azure.serverless.AzureSparkServerlessCluster;
2829
import com.microsoft.azure.sparkserverless.serverexplore.sparkserverlessnode.SparkServerlessClusterOps;
2930
import com.microsoft.azure.sparkserverless.serverexplore.ui.SparkServerlessClusterDestoryDialog;
3031
import com.microsoft.azure.sparkserverless.serverexplore.ui.SparkServerlessClusterMonitorDialog;
@@ -45,7 +46,10 @@ public SparkServerlessClusterOpsCtrl(@NotNull SparkServerlessClusterOps sparkSer
4546
.observeOn(ideSchedulers.dispatchUIThread())
4647
.subscribe(triplet -> {
4748
log().info(String.format("Destroy message received. AdlAccount: %s, cluster: %s, currentNode: %s",
48-
triplet.getLeft().getName(), triplet.getMiddle(), triplet.getRight().getName()));
49+
triplet.getLeft().getName(),
50+
// Type cast is necessary for DestroyableCluster
51+
((AzureSparkServerlessCluster) triplet.getMiddle()).getName(),
52+
triplet.getRight().getName()));
4953
SparkServerlessClusterDestoryDialog destroyDialog = new SparkServerlessClusterDestoryDialog(
5054
triplet.getRight(), triplet.getMiddle());
5155
destroyDialog.show();
@@ -65,7 +69,7 @@ public SparkServerlessClusterOpsCtrl(@NotNull SparkServerlessClusterOps sparkSer
6569
.observeOn(ideSchedulers.dispatchUIThread())
6670
.subscribe(pair -> {
6771
log().info(String.format("Monitor message received. cluster: %s, node: %s",
68-
pair.getLeft(), pair.getRight()));
72+
pair.getLeft().getName(), pair.getRight().getName()));
6973
SparkServerlessClusterMonitorDialog monitorDialog = new SparkServerlessClusterMonitorDialog(
7074
pair.getRight(), pair.getLeft());
7175
monitorDialog.show();
@@ -75,7 +79,7 @@ public SparkServerlessClusterOpsCtrl(@NotNull SparkServerlessClusterOps sparkSer
7579
.observeOn(ideSchedulers.dispatchUIThread())
7680
.subscribe(pair -> {
7781
log().info(String.format("Update message received. cluster: %s, node: %s",
78-
pair.getLeft(), pair.getRight()));
82+
pair.getLeft().getName(), pair.getRight().getName()));
7983
SparkServerlessClusterUpdateDialog updateDialog = new SparkServerlessClusterUpdateDialog(
8084
pair.getRight(), pair.getLeft());
8185
updateDialog.show();

0 commit comments

Comments
 (0)