Skip to content

Commit 10b507d

Browse files
authored
[Improve] Fix typo. (#4246)
1 parent 7983e0a commit 10b507d

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkClusterServiceImpl.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -348,11 +348,11 @@ public void remove(Long id) {
348348
|| FlinkDeployMode.isKubernetesSessionMode(flinkCluster.getDeployMode())) {
349349
ApiAlertException.throwIfTrue(
350350
ClusterState.isRunning(flinkCluster.getClusterStateEnum()),
351-
"Flink cluster is running, cannot be delete, please check.");
351+
"Flink cluster is running, cannot be deleted, please check.");
352352
}
353353
ApiAlertException.throwIfTrue(
354354
applicationInfoService.existsByClusterId(id),
355-
"Some app on this cluster, the cluster cannot be delete, please check.");
355+
"Some apps on this cluster, the cluster cannot be deleted, please check.");
356356
removeById(id);
357357
}
358358

0 commit comments

Comments
 (0)