[bahir-flink] branch master updated: [BAHIR-266] Redis - Fix java8 stream use (#117)

[eskabetxe]

This is an automated email from the ASF dual-hosted git repository.

eskabetxe pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/bahir-flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 464a08f  [BAHIR-266] Redis - Fix java8 stream use (#117)
464a08f is described below

commit 464a08f84c7df9c93c58f6456fbd709100fd2620
Author: yiksanchan <evan.chanyik...@gmail.com>
AuthorDate: Fri Mar 12 01:42:17 2021 +0800

    [BAHIR-266] Redis - Fix java8 stream use (#117)
---
 .../redis/common/config/handler/FlinkJedisClusterConfigHandler.java  | 2 +-
 .../redis/common/config/handler/FlinkJedisSentinelConfigHandler.java | 5 ++---
 2 files changed, 3 insertions(+), 4 deletions(-)

diff --git 
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/handler/FlinkJedisClusterConfigHandler.java
 
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/handler/FlinkJedisClusterConfigHandler.java
index 9e85182..09d8911 100644
--- 
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/handler/FlinkJedisClusterConfigHandler.java
+++ 
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/handler/FlinkJedisClusterConfigHandler.java
@@ -43,7 +43,7 @@ public class FlinkJedisClusterConfigHandler implements 
FlinkJedisConfigHandler {
     public FlinkJedisConfigBase createFlinkJedisConfig(Map<String, String> 
properties) {
         Preconditions.checkArgument(properties.containsKey(REDIS_NODES), 
"nodes should not be null in cluster mode");
         String nodesInfo = properties.get(REDIS_NODES);
-        Set<InetSocketAddress> nodes = 
Arrays.asList(nodesInfo.split(",")).stream().map(r -> {
+        Set<InetSocketAddress> nodes = 
Arrays.stream(nodesInfo.split(",")).map(r -> {
             String[] arr = r.split(":");
             return new InetSocketAddress(arr[0].trim(), 
Integer.parseInt(arr[1].trim()));
         }).collect(Collectors.toSet());
diff --git 
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/handler/FlinkJedisSentinelConfigHandler.java
 
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/handler/FlinkJedisSentinelConfigHandler.java
index 72065d5..b621f97 100644
--- 
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/handler/FlinkJedisSentinelConfigHandler.java
+++ 
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/handler/FlinkJedisSentinelConfigHandler.java
@@ -25,10 +25,10 @@ import static 
org.apache.flink.streaming.connectors.redis.descriptor.RedisValida
 
 import java.util.Arrays;
 import java.util.HashMap;
+import java.util.HashSet;
 import java.util.Map;
 import java.util.Objects;
 import java.util.Set;
-import java.util.stream.Collectors;
 import 
org.apache.flink.streaming.connectors.redis.common.config.FlinkJedisConfigBase;
 import 
org.apache.flink.streaming.connectors.redis.common.config.FlinkJedisSentinelConfig;
 import 
org.apache.flink.streaming.connectors.redis.common.hanlder.FlinkJedisConfigHandler;
@@ -41,8 +41,7 @@ public class FlinkJedisSentinelConfigHandler implements 
FlinkJedisConfigHandler
         String sentinelsInfo = properties.computeIfAbsent(SENTINELS_INFO, 
null);
         Objects.requireNonNull(masterName, "master should not be null in 
sentinel mode");
         Objects.requireNonNull(sentinelsInfo, "sentinels should not be null in 
sentinel mode");
-        Set<String> sentinels = Arrays.asList(sentinelsInfo.split(","))
-                .stream().collect(Collectors.toSet());
+        Set<String> sentinels = new 
HashSet<>(Arrays.asList(sentinelsInfo.split(",")));
         String sentinelsPassword = 
properties.computeIfAbsent(SENTINELS_PASSWORD, null);
         if (sentinelsPassword != null && sentinelsPassword.trim().isEmpty()) {
             sentinelsPassword = null;