commit 3744457437ef74696747911897bb746dc2dde6c9
author Hyeonho Kim <jwalag87@gmail.com> Wed May 31 01:11:25 2023 +0900
committer GitHub <noreply@github.com> Tue May 30 18:11:25 2023 +0200
tree 10d294d6f7809173c9f75f2062b15facc0d88810
parent cd8f61e2808d9e62650632e5e1ce5a38843ef346

[BAHIR-285] Redis: fix typo error in log message

flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisContainer.java

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 5857d25..61d126c 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
@@ -167,7 +167,7 @@
             jedis.lpush(listName, value);
         } catch (Exception e) {
             if (LOG.isErrorEnabled()) {
-                LOG.error("Cannot send Redis message with command LUSH to list {} error message {}",
+                LOG.error("Cannot send Redis message with command LPUSH to list {} error message {}",
                     listName, e.getMessage());
             }
             throw e;
@@ -184,7 +184,7 @@
             jedis.sadd(setName, value);
         } catch (Exception e) {
             if (LOG.isErrorEnabled()) {
-                LOG.error("Cannot send Redis message with command RPUSH to set {} error message {}",
+                LOG.error("Cannot send Redis message with command SADD to set {} error message {}",
                     setName, e.getMessage());
             }
             throw e;