[
https://issues.apache.org/jira/browse/BAHIR-257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
João Boto resolved BAHIR-257.
-----------------------------
Resolution: Fixed
> RedisDescriptorTest add TableFactory sql operate Test
> -------------------------------------------------------
>
> Key: BAHIR-257
> URL: https://issues.apache.org/jira/browse/BAHIR-257
> Project: Bahir
> Issue Type: Test
> Components: Flink Streaming Connectors
> Affects Versions: Flink-1.0
> Reporter: housezhang
> Assignee: housezhang
> Priority: Trivial
> Fix For: Flink-Next
>
> Original Estimate: 2h
> Remaining Estimate: 2h
>
> 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");
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
