add zk session expired error

Author: todd5167

core/src/main/java/com/dtstack/flink/sql/enums/EConnectionErrorCode.java

@@ -30,7 +30,7 @@
  */
 public enum EConnectionErrorCode {
     ERROR_NOT_MATCH(0, "错误信息未匹配", new String[]{}),
-    CONN_DB_INVALID(1, "数据库连接失效，请重新打开", new String[]{"the last packet successfully received from the server was"}),
+    CONN_DB_INVALID(1, "数据库连接失效，请重新打开", new String[]{"the last packet successfully received from the server was", "Zookeeper session has been expired"}),
     CONN_DB_FAILED(2, "数据库连接失败，请检查用户名或密码是否正确", new String[]{"Access denied for user"}),
     DB_TABLE_NOT_EXIST(3, "操作的表名不存在", new String[]{"doesn't exist"});
 

core/src/test/java/com/dtstack/flink/sql/side/EConnectionErrorCodeTest.java

@@ -34,6 +34,10 @@ public void testResolveErrorCodeFromException(){
         EConnectionErrorCode errorCode =
                 EConnectionErrorCode.resolveErrorCodeFromException(new Exception("The last packet successfully received from the server was 179 milliseconds"));
 
+        EConnectionErrorCode ckSessionExpired =
+                EConnectionErrorCode.resolveErrorCodeFromException(new Exception("Excepetion: Zookeeper session has been expired"));
+
         Assert.assertEquals(errorCode, EConnectionErrorCode.CONN_DB_INVALID);
+        Assert.assertEquals(ckSessionExpired, EConnectionErrorCode.CONN_DB_INVALID);
     }
 }