[BAHIR-257] RedisDescriptorTest add TableFactory sql operate Test

• Type: Test
• Status: Resolved
• Priority: Trivial
• Resolution: Fixed
• Affects Version/s: Flink-1.0
• Fix Version/s: Flink-1.1.0
• Component/s: Flink Streaming Connectors
• Assignee: housezhang
• Reporter: housezhang
• Created: 15/Jan/21 04:47
• Updated: 22/Jan/21 14:22
• Resolved: 22/Jan/21 14:21

Description

 use flink sql to operator redis ,include create redis sql etc  like bellow:

tableEnv.executeSql("CREATE TABLE redis (key STRING, number BIGINT) WITH ('connector.type'='redis'," +
"'redis-mode'='cluster', 'key.ttl' = '70000','command'='INCRBY_EX','cluster-nodes'='" + REDIS_HOST + ":" + REDIS_PORT + "')");

tableEnv.executeSql("insert into redis select * from t1");

Issue Links

• links to: GitHub Pull Request #107
• links to: GitHub Pull Request #108