commit b618a77cca2e44be86f18607e21a6b2d2bf8dd39
author yiksanchan <evan.chanyiksan@gmail.com> Fri Mar 12 16:16:37 2021 +0800
committer GitHub <noreply@github.com> Fri Mar 12 09:16:37 2021 +0100
tree 74920d10966fc5fd2369f040a670d2f9f7dbc6df
parent cabee21712283dddd2f7c6f4e60e42a848a728f1

[BAHIR-267] Fix FlinkJedisConfig names in toString methods (#120)

flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisClusterConfig.java

diff --git a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisClusterConfig.java b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisClusterConfig.java
index f05dfd8..c56ac14 100644
--- a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisClusterConfig.java
+++ b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisClusterConfig.java
@@ -191,7 +191,7 @@
 
     @Override
     public String toString() {
-        return "JedisClusterConfig{" +
+        return "FlinkJedisClusterConfig{" +
             "nodes=" + nodes +
             ", timeout=" + connectionTimeout +
             ", maxRedirections=" + maxRedirections +

flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisPoolConfig.java

diff --git a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisPoolConfig.java b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisPoolConfig.java
index 7c37ecb..3f8fc2f 100644
--- a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisPoolConfig.java
+++ b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisPoolConfig.java
@@ -201,7 +201,7 @@
 
     @Override
     public String toString() {
-        return "JedisPoolConfig{" +
+        return "FlinkJedisPoolConfig{" +
             "host='" + host + '\'' +
             ", port=" + port +
             ", timeout=" + connectionTimeout +

flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisSentinelConfig.java

diff --git a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisSentinelConfig.java b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisSentinelConfig.java
index 2fb87b9..928f5e8 100644
--- a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisSentinelConfig.java
+++ b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisSentinelConfig.java
@@ -236,7 +236,7 @@
 
     @Override
     public String toString() {
-        return "JedisSentinelConfig{" +
+        return "FlinkJedisSentinelConfig{" +
             "masterName='" + masterName + '\'' +
             ", connectionTimeout=" + connectionTimeout +
             ", soTimeout=" + soTimeout +