[bahir-flink] branch master updated: [BAHIR-254] Update Redis to remove usage of deprecated methods (#102)

[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 d169452  [BAHIR-254] Update Redis to remove usage of deprecated 
methods (#102)
d169452 is described below

commit d16945214a1b23c70dd02b7bcfeddf69d0aca7a5
Author: housezhang <pop_1...@126.com>
AuthorDate: Mon Jan 11 14:57:46 2021 +0800

    [BAHIR-254] Update Redis to remove usage of deprecated methods (#102)
    
    RedisDescriptorTest that uses SQL or TAB API will run exception(flink1.11)
    because use Deprecated method and field
    
    Co-authored-by: house.zhang <>
---
 .../flink/streaming/connectors/redis/RedisTableSinkFactory.java       | 2 +-
 .../apache/flink/streaming/connectors/redis/RedisDescriptorTest.java  | 4 +---
 2 files changed, 2 insertions(+), 4 deletions(-)

diff --git 
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/RedisTableSinkFactory.java
 
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/RedisTableSinkFactory.java
index b454fee..0ddbcea 100644
--- 
a/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/RedisTableSinkFactory.java
+++ 
b/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/RedisTableSinkFactory.java
@@ -60,7 +60,7 @@ public class RedisTableSinkFactory implements 
StreamTableSinkFactory<Tuple2<Bool
         properties.add(REDIS_SENTINEL);
         properties.add(REDIS_KEY_TTL);
         // schema
-        properties.add(SCHEMA + ".#." + SCHEMA_TYPE);
+        properties.add(SCHEMA + ".#." + SCHEMA_DATA_TYPE);
         properties.add(SCHEMA + ".#." + SCHEMA_NAME);
         properties.add(SCHEMA + ".#." + SCHEMA_FROM);
         // format wildcard
diff --git 
a/flink-connector-redis/src/test/java/org/apache/flink/streaming/connectors/redis/RedisDescriptorTest.java
 
b/flink-connector-redis/src/test/java/org/apache/flink/streaming/connectors/redis/RedisDescriptorTest.java
index 9b52d6a..0e4ef17 100644
--- 
a/flink-connector-redis/src/test/java/org/apache/flink/streaming/connectors/redis/RedisDescriptorTest.java
+++ 
b/flink-connector-redis/src/test/java/org/apache/flink/streaming/connectors/redis/RedisDescriptorTest.java
@@ -68,9 +68,7 @@ public class RedisDescriptorTest extends  RedisITCaseBase{
                 .field("v", TypeInformation.of(Long.class)))
                 .createTemporaryTable("redis");
 
-
-        tableEnvironment.sqlUpdate("insert into redis select k, v from t1");
-        env.execute("Test Redis Table");
+        tableEnvironment.executeSql("insert into redis select k, v from t1");
     }