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/11 17:35:31 UTC
[bahir-flink] branch master updated: [BAHIR-265] Fix Redis log
messages (#118)
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 <ev...@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;