jedis npe check

Author: todd5167

redis5/redis5-side/redis-all-side/src/main/java/com/dtstack/flink/sql/side/redis/RedisAllReqRow.java

@@ -103,6 +103,7 @@ protected void reloadCache() {
             loadData(newCache);
         } catch (SQLException e) {
             LOG.error("", e);
+            throw new RuntimeException(e);
         }
 
         cacheRef.set(newCache);
@@ -160,21 +161,22 @@ private void loadData(Map<String, Map<String, String>> tmpCache) throws SQLExcep
         JedisCommands jedis = null;
         try {
             StringBuilder keyPattern = new StringBuilder(tableInfo.getTableName());
-            for(String key : tableInfo.getPrimaryKeys()){
+            for (String key : tableInfo.getPrimaryKeys()) {
                 keyPattern.append("_").append("*");
-            };
+            }
             jedis = getJedisWithRetry(CONN_RETRY_NUM);
+            if (null == jedis) {
+                throw new RuntimeException("redis all load data error,get jedis commands error!");
+            }
             Set<String> keys = getRedisKeys(RedisType.parse(tableInfo.getRedisType()), jedis, keyPattern.toString());
-            if(CollectionUtils.isEmpty(keys)){
+            if (CollectionUtils.isEmpty(keys)) {
                 return;
             }
-            for(String key : keys){
+            for (String key : keys) {
                 tmpCache.put(key, jedis.hgetAll(key));
             }
-        } catch (Exception e){
-            LOG.error("", e);
         } finally {
-            if (jedis != null){
+            if (jedis != null) {
                 try {
                     ((Closeable) jedis).close();
                 } catch (IOException e) {