[bahir-flink] branch master updated: [HOTFIX] Fix NPE on getAdditionalTTL (#77)

[lresende]

This is an automated email from the ASF dual-hosted git repository.

lresende 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 a58b454  [HOTFIX] Fix NPE on getAdditionalTTL (#77)
a58b454 is described below

commit a58b454798e61cf6ed621cb6598d513d2aaccbbc
Author: zhangmang <zhangma...@163.com>
AuthorDate: Tue Apr 7 11:39:32 2020 +0800

    [HOTFIX] Fix NPE on getAdditionalTTL (#77)
    
    Fix SetMapper to return Integer to avoid NPE as
    `ttl` returns an Integer, but `getTtl()` returns an int.
---
 .../streaming/connectors/redis/common/mapper/row/RowRedisMapper.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/RowRedisMapper.java
 
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/RowRedisMapper.java
index fe294b8..c62e1d6 100644
--- 
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/RowRedisMapper.java
+++ 
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/RowRedisMapper.java
@@ -43,7 +43,7 @@ public abstract class RowRedisMapper implements 
RedisMapper<Tuple2<Boolean, Row>
 
     private RedisCommand redisCommand;
 
-    public int getTtl() {
+    public Integer getTtl() {
         return ttl;
     }