[bahir-flink] branch master updated: [BAHIR-285] Redis: fix typo error in log message

[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 3744457  [BAHIR-285] Redis: fix typo error in log message
3744457 is described below

commit 3744457437ef74696747911897bb746dc2dde6c9
Author: Hyeonho Kim <jwala...@gmail.com>
AuthorDate: Wed May 31 01:11:25 2023 +0900

    [BAHIR-285] Redis: fix typo error in log message
---
 .../streaming/connectors/redis/common/container/RedisContainer.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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 @@ public class RedisContainer implements 
RedisCommandsContainer, Closeable {
             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 @@ public class RedisContainer implements 
RedisCommandsContainer, Closeable {
             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;