password is null

yanxi0227 · yanxi0227 · commit b41cc0ea7f3e · 2018-12-10T11:36:58.000+08:00
diff --git a/redis5/redis5-side/redis-async-side/src/main/java/com/dtstack/flink/sql/side/redis/RedisAsyncReqRow.java b/redis5/redis5-side/redis-async-side/src/main/java/com/dtstack/flink/sql/side/redis/RedisAsyncReqRow.java
@@ -80,6 +80,8 @@ private void buildRedisClient(RedisSideTableInfo tableInfo){
         String password = redisSideTableInfo.getPassword();
         if (password != null){
             password = password + "@";
+        } else {
+            password = "";
         }
         String database = redisSideTableInfo.getDatabase();
         if (database == null){
diff --git a/redis5/redis5-sink/pom.xml b/redis5/redis5-sink/pom.xml
@@ -26,7 +26,7 @@
         <dependency>
             <groupId>redis.clients</groupId>
             <artifactId>jedis</artifactId>
-            <version>2.8.0</version>
+            <version>2.9.0</version>
         </dependency>
     </dependencies>
 

Original file line number	Diff line number	Diff line change
`@@ -80,6 +80,8 @@ private void buildRedisClient(RedisSideTableInfo tableInfo){`
`80`	`80`	`String password = redisSideTableInfo.getPassword();`
`81`	`81`	`if (password != null){`
`82`	`82`	`password = password + "@";`
	`83`	`+ } else {`
	`84`	`+ password = "";`
`83`	`85`	`}`
`84`	`86`	`String database = redisSideTableInfo.getDatabase();`
`85`	`87`	`if (database == null){`