Skip to content

Commit

Permalink
[INLONG-877][Improve] Update document of TubeMQ extract node (#882)
Browse files Browse the repository at this point in the history
  • Loading branch information
fancycoderzf authored Oct 17, 2023
1 parent 6160036 commit c61cc6f
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
4 changes: 2 additions & 2 deletions docs/data_node/extract_node/tube.md
Original file line number Diff line number Diff line change
Expand Up @@ -46,9 +46,9 @@ Flink SQL> CREATE TABLE tube_extract_node (
) WITH (
'connector' = 'tubemq',
'topic' = 'topicName',
'masterRpc' = 'rpcUrl', -- 127.0.0.1:8715
'master.rpc' = 'rpcUrl', -- 127.0.0.1:8715
'format' = 'json',
'groupId' = 'groupName');
'group.name' = 'groupName');

-- Read data from tube_extract_node
Flink SQL> SELECT * FROM tube_extract_node;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -45,9 +45,9 @@ Flink SQL> CREATE TABLE tube_extract_node (
) WITH (
'connector' = 'tubemq',
'topic' = 'topicName',
'masterRpc' = 'rpcUrl', -- 127.0.0.1:8715
'master.rpc' = 'rpcUrl', -- 127.0.0.1:8715
'format' = 'json',
'groupId' = 'groupName');
'group.name' = 'groupName');

-- Read data from tube_extract_node
Flink SQL> SELECT * FROM tube_extract_node;
Expand Down

0 comments on commit c61cc6f

Please sign in to comment.