You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@bahir.apache.org by lr...@apache.org on 2021/01/11 06:58:27 UTC
[bahir-flink] branch master updated: [BAHIR-254] Update Redis to
remove usage of deprecated methods (#102)
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 <po...@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");
}