[bahir-flink] branch master updated: [BAHIR-265] Fix Redis log messages (#118)

[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 9dcb7d6  [BAHIR-265] Fix Redis log messages (#118)
9dcb7d6 is described below

commit 9dcb7d623cb39b192d8004295d6dc4c9dcbbff96
Author: yiksanchan <evan.chanyik...@gmail.com>
AuthorDate: Fri Mar 12 01:35:24 2021 +0800

    [BAHIR-265] Fix Redis log messages (#118)
---
 .../connectors/redis/common/container/RedisClusterContainer.java  | 2 +-
 .../connectors/redis/common/container/RedisContainer.java         | 8 ++++----
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisClusterContainer.java
 
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisClusterContainer.java
index 307d93e..d61716b 100644
--- 
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisClusterContainer.java
+++ 
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisClusterContainer.java
@@ -257,7 +257,7 @@ public class RedisClusterContainer implements 
RedisCommandsContainer, Closeable
             jedisCluster.incrBy(key, value);
         } catch (Exception e) {
             if (LOG.isErrorEnabled()) {
-                LOG.error("Cannot send Redis message with command incrby to 
key {} with increment {} and tll {} error message {}",
+                LOG.error("Cannot send Redis message with command incrby to 
key {} with increment {} error message {}",
                         key, value, e.getMessage());
             }
             throw e;
diff --git 
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisContainer.java
 
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisContainer.java
index 46309ab..539192b 100644
--- 
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisContainer.java
+++ 
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisContainer.java
@@ -335,7 +335,7 @@ public class RedisContainer implements 
RedisCommandsContainer, Closeable {
             }
         } catch (Exception e) {
             if (LOG.isErrorEnabled()) {
-                LOG.error("Cannot send Redis with incrby command with 
increment {}  with ttl {} error message {}",
+                LOG.error("Cannot send Redis with incrby command to key {} 
with increment {}  with ttl {} error message {}",
                         key, value, ttl, e.getMessage());
             }
             throw e;
@@ -355,7 +355,7 @@ public class RedisContainer implements 
RedisCommandsContainer, Closeable {
             }
         } catch (Exception e) {
             if (LOG.isErrorEnabled()) {
-                LOG.error("Cannot send Redis with decrBy command with 
decrement {}  with ttl {} error message {}",
+                LOG.error("Cannot send Redis with decrBy command to key {} 
with decrement {}  with ttl {} error message {}",
                         key, value, ttl, e.getMessage());
             }
             throw e;
@@ -372,7 +372,7 @@ public class RedisContainer implements 
RedisCommandsContainer, Closeable {
             jedis.incrBy(key, value);
         } catch (Exception e) {
             if (LOG.isErrorEnabled()) {
-                LOG.error("Cannot send Redis with incrby command with 
increment {}  error message {}",
+                LOG.error("Cannot send Redis with incrby command to key {} 
with increment {}  error message {}",
                         key, value, e.getMessage());
             }
             throw e;
@@ -389,7 +389,7 @@ public class RedisContainer implements 
RedisCommandsContainer, Closeable {
             jedis.decrBy(key, value);
         } catch (Exception e) {
             if (LOG.isErrorEnabled()) {
-                LOG.error("Cannot send Redis with decrBy command with 
increment {}  error message {}",
+                LOG.error("Cannot send Redis with decrBy command to key {} 
with increment {}  error message {}",
                         key, value, e.getMessage());
             }
             throw e;