You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@bahir.apache.org by es...@apache.org on 2021/03/12 08:18:08 UTC
[bahir-flink] branch master updated: [BAHIR-267] Fix
FlinkJedisConfig names in toString methods (#120)
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 <ev...@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 +