| commit | d16945214a1b23c70dd02b7bcfeddf69d0aca7a5 | [log] [tgz] |
|---|---|---|
| author | housezhang <pop_1987@126.com> | Mon Jan 11 14:57:46 2021 +0800 |
| committer | GitHub <noreply@github.com> | Sun Jan 10 22:57:46 2021 -0800 |
| tree | 57371f703dabd2d936afc909b36d7679fd215e15 | |
| parent | f0b3e1e04930b79b277cfc7ebe3552db246578e9 [diff] |
[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 <>
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 @@ 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 @@ .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"); }