diff --git a/chunjun-core/src/main/java/com/dtstack/chunjun/options/Options.java b/chunjun-core/src/main/java/com/dtstack/chunjun/options/Options.java
index 7dff980b09..632b827e32 100644
--- a/chunjun-core/src/main/java/com/dtstack/chunjun/options/Options.java
+++ b/chunjun-core/src/main/java/com/dtstack/chunjun/options/Options.java
@@ -254,7 +254,17 @@ public void setJobType(String jobType) {
     }
 
     public String getFlinkxDistDir() {
-        return flinkxDistDir;
+        String flinkxDistDir = this.flinkxDistDir;
+        String chunjunDistDir = this.chunjunDistDir;
+        String distDir;
+
+        if (StringUtils.isNotBlank(flinkxDistDir)) {
+            LOG.warn("Option 'flinkxDistDir' is deprecated, please replace with 'chunjunDistDir'.");
+            distDir = flinkxDistDir;
+        } else {
+            distDir = chunjunDistDir;
+        }
+        return distDir;
     }
 
     public void setFlinkxDistDir(String flinkxDistDir) {
@@ -262,7 +272,18 @@ public void setFlinkxDistDir(String flinkxDistDir) {
     }
 
     public String getRemoteFlinkxDistDir() {
-        return remoteFlinkxDistDir;
+        String remoteFlinkxDistDir = this.remoteFlinkxDistDir;
+        String remoteChunJunDistDir = this.remoteChunJunDistDir;
+        String remoteDir;
+
+        if (StringUtils.isNotBlank(remoteFlinkxDistDir)) {
+            LOG.warn(
+                    "Option 'remoteFlinkxDistDir' is deprecated, please replace with 'remoteChunJunDistDir'.");
+            remoteDir = remoteFlinkxDistDir;
+        } else {
+            remoteDir = remoteChunJunDistDir;
+        }
+        return remoteDir;
     }
 
     public void setRemoteFlinkxDistDir(String remoteFlinkxDistDir) {