fix var name

vesoft-inc · Nov 18, 2021 · 7d355b4 · 7d355b4
1 parent d1509c3
commit 7d355b4
Showing 1 changed file with 8 additions and 8 deletions.
diff --git a/...ector/src/main/java/org.apache.flink/connector/nebula/connection/NebulaClientOptions.java b/...ector/src/main/java/org.apache.flink/connector/nebula/connection/NebulaClientOptions.java
@@ -36,7 +36,7 @@ public class NebulaClientOptions implements Serializable {
 
     private final SSLSighType sslSighType;
 
-    private final CASignParams caSSLSignParams;
+    private final CASignParams caSignParams;
 
     private final SelfSignParams selfSignParams;
 
@@ -45,7 +45,7 @@ private NebulaClientOptions(String metaAddress, String graphAddress, String user
                                 String password, int timeout, int connectRetry,
                                 boolean enableGraphSSL, boolean enableMetaSSL,
                                 boolean enableStorageSSL,
-                                SSLSighType sslSighType, CASignParams caSSLSignParams,
+                                SSLSighType sslSighType, CASignParams caSignParams,
                                 SelfSignParams selfSignParams) {
         this.metaAddress = metaAddress;
         this.graphAddress = graphAddress;
@@ -57,7 +57,7 @@ private NebulaClientOptions(String metaAddress, String graphAddress, String user
         this.enableMetaSSL = enableMetaSSL;
         this.enableStorageSSL = enableStorageSSL;
         this.sslSighType = sslSighType;
-        this.caSSLSignParams = caSSLSignParams;
+        this.caSignParams = caSignParams;
         this.selfSignParams = selfSignParams;
     }
 
@@ -107,7 +107,7 @@ public SSLSighType getSSLSighType() {
     }
 
     public CASignParams getCaSignParam() {
-        return caSSLSignParams;
+        return caSignParams;
     }
 
     public SelfSignParams getSelfSignParam() {
@@ -130,7 +130,7 @@ public static class NebulaClientOptionsBuilder {
         private boolean enableMetaSSL = false;
         private boolean enableStorageSSL = false;
         private SSLSighType sslSighType = null;
-        private CASignParams caSSLSignParams = null;
+        private CASignParams caSignParams = null;
         private SelfSignParams selfSignParams = null;
 
         public NebulaClientOptionsBuilder setMetaAddress(String metaAddress) {
@@ -186,7 +186,7 @@ public NebulaClientOptionsBuilder setSSLSignType(SSLSighType sslSighType) {
 
         public NebulaClientOptionsBuilder setCaSignParam(String caCrtFilePath, String crtFilePath,
                                                          String keyFilePath) {
-            this.caSSLSignParams = new CASignParams(caCrtFilePath, crtFilePath, keyFilePath);
+            this.caSignParams = new CASignParams(caCrtFilePath, crtFilePath, keyFilePath);
             return this;
         }
 
@@ -213,7 +213,7 @@ public NebulaClientOptions build() {
                 }
                 switch (sslSighType) {
                     case CA:
-                        if (caSSLSignParams == null) {
+                        if (caSignParams == null) {
                             throw new IllegalArgumentException("ssl is enabled and sign type is "
                                     + "CA, caSignParam must not be null");
                         }
@@ -241,7 +241,7 @@ public NebulaClientOptions build() {
                     enableMetaSSL,
                     enableStorageSSL,
                     sslSighType,
-                    caSSLSignParams,
+                    caSignParams,
                     selfSignParams);
         }
     }