You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@bahir.apache.org by "ASF subversion and git services (Jira)" <ji...@apache.org> on 2021/01/22 14:23:00 UTC
[jira] [Commented] (BAHIR-257) RedisDescriptorTest add TableFactory
sql operate Test
[ https://issues.apache.org/jira/browse/BAHIR-257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17270167#comment-17270167 ]
ASF subversion and git services commented on BAHIR-257:
-------------------------------------------------------
Commit 567a887fbfb6a95f870be50584d3fce820a76af1 in bahir-flink's branch refs/heads/master from housezhang
[ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=567a887 ]
[BAHIR-257] RedisDescriptorTest add TableFactory sql operate test (#108)
Co-authored-by: house.zhang
> 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)