diff --git a/flinkx-clients/src/main/java/com/dtstack/flinkx/client/Launcher.java b/flinkx-clients/src/main/java/com/dtstack/flinkx/client/Launcher.java
index 0f3aa9f5b7..71f8e57463 100644
--- a/flinkx-clients/src/main/java/com/dtstack/flinkx/client/Launcher.java
+++ b/flinkx-clients/src/main/java/com/dtstack/flinkx/client/Launcher.java
@@ -126,7 +126,7 @@ public static void main(String[] args) throws Exception {
         clusterClientHelper.submit(jobDeployer);
     }
 
-    private static void findDefaultConfigDir(Options launcherOptions) {
+    private static void findDefaultConfigDir(Options launcherOptions) throws ClusterDeploymentException {
         findDefaultFlinkxDistDir(launcherOptions);
 
         if (ClusterMode.local.name().equalsIgnoreCase(launcherOptions.getMode())) {
@@ -172,7 +172,7 @@ private static void findDefaultFlinkConf(Options launcherOptions) {
         }
     }
 
-    private static void findDefaultFlinkxDistDir(Options launcherOptions) {
+    private static void findDefaultFlinkxDistDir(Options launcherOptions) throws ClusterDeploymentException {
         String distDir = launcherOptions.getFlinkxDistDir();
         if (StringUtils.isEmpty(distDir)) {
             String flinkxHome = getSystemProperty(KEY_FLINKX_HOME);
@@ -187,6 +187,9 @@ private static void findDefaultFlinkxDistDir(Options launcherOptions) {
                 launcherOptions.setFlinkxDistDir(distDir);
             }
         }
+        if (StringUtils.isEmpty(distDir)) {
+            notConfiguredException(KEY_FLINKX_HOME);
+        }
         System.setProperty(ConfigConstants.ENV_FLINK_PLUGINS_DIR, distDir);
     }
 
@@ -198,4 +201,8 @@ private static String getSystemProperty(String name) {
 
         return property;
     }
+
+    private static void notConfiguredException(String propertyKey) throws ClusterDeploymentException {
+        throw new ClusterDeploymentException(propertyKey + " is not configured.");
+    }
 }