[bahir-flink] branch master updated: [BAHIR-267] Fix FlinkJedisConfig names in toString methods (#120)

[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 b618a77  [BAHIR-267] Fix FlinkJedisConfig names in toString methods 
(#120)
b618a77 is described below

commit b618a77cca2e44be86f18607e21a6b2d2bf8dd39
Author: yiksanchan <evan.chanyik...@gmail.com>
AuthorDate: Fri Mar 12 16:16:37 2021 +0800

    [BAHIR-267] Fix FlinkJedisConfig names in toString methods (#120)
---
 .../connectors/redis/common/config/FlinkJedisClusterConfig.java         | 2 +-
 .../streaming/connectors/redis/common/config/FlinkJedisPoolConfig.java  | 2 +-
 .../connectors/redis/common/config/FlinkJedisSentinelConfig.java        | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

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 @@ public class FlinkJedisClusterConfig extends 
FlinkJedisConfigBase {
 
     @Override
     public String toString() {
-        return "JedisClusterConfig{" +
+        return "FlinkJedisClusterConfig{" +
             "nodes=" + nodes +
             ", timeout=" + connectionTimeout +
             ", maxRedirections=" + maxRedirections +
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 @@ public class FlinkJedisPoolConfig extends 
FlinkJedisConfigBase {
 
     @Override
     public String toString() {
-        return "JedisPoolConfig{" +
+        return "FlinkJedisPoolConfig{" +
             "host='" + host + '\'' +
             ", port=" + port +
             ", timeout=" + connectionTimeout +
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 @@ public class FlinkJedisSentinelConfig extends 
FlinkJedisConfigBase {
 
     @Override
     public String toString() {
-        return "JedisSentinelConfig{" +
+        return "FlinkJedisSentinelConfig{" +
             "masterName='" + masterName + '\'' +
             ", connectionTimeout=" + connectionTimeout +
             ", soTimeout=" + soTimeout +