You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ka...@apache.org on 2022/09/26 09:41:51 UTC
[rocketmq-streams] branch main updated: maintain(doc) design

This is an automated email from the ASF dual-hosted git repository.

karp pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-streams.git


The following commit(s) were added to refs/heads/main by this push:
     new fda2a4ad maintain(doc) design
     new 150387f6 Merge pull request #222 from ni-ze/supportRsqldb
fda2a4ad is described below

commit fda2a4ad5705c61e912bf71be0847bc9bdb033d7
Author: 维章 <ni...@alibaba-inc.com>
AuthorDate: Mon Sep 26 17:39:42 2022 +0800

    maintain(doc) design
---
 ...346\225\264\344\275\223\346\236\266\346\236\204.md" |  10 +++++-----
 ...MQ-streams\346\211\251\347\274\251\345\256\271.png" | Bin 0 -> 142453 bytes
 docs/images/logo.jpeg                                  | Bin 23554 -> 0 bytes
 "docs/images/\346\211\251\345\256\271\345\211\215.png" | Bin 56733 -> 0 bytes
 "docs/images/\346\211\251\347\274\251\345\256\271.png" | Bin 0 -> 153620 bytes
 ...46\266\210\350\264\271\346\250\241\345\236\213.png" | Bin 0 -> 117975 bytes
 "docs/images/\347\212\266\346\200\201.png"             | Bin 47527 -> 0 bytes
 ...47\212\266\346\200\201\345\255\230\345\202\250.png" | Bin 0 -> 84924 bytes
 "docs/images/\347\274\251\345\256\271.png"             | Bin 51087 -> 0 bytes
 9 files changed, 5 insertions(+), 5 deletions(-)

diff --git "a/docs/design/1.RocketMQ-streams\346\225\264\344\275\223\346\236\266\346\236\204.md" "b/docs/design/1.RocketMQ-streams\346\225\264\344\275\223\346\236\266\346\236\204.md"
index 8e564a8c..41dc250c 100644
--- "a/docs/design/1.RocketMQ-streams\346\225\264\344\275\223\346\236\266\346\236\204.md"
+++ "b/docs/design/1.RocketMQ-streams\346\225\264\344\275\223\346\236\266\346\236\204.md"
@@ -7,9 +7,9 @@
 shuffle topic消费。如果还涉及count之类有状态算子，那么计算时需要读写状态，在窗口触发之后将计算结果写出。
 
 
-### 任务并行度模型
+### 消费模型
 
-![img_2.png](../images/扩容前.png)
+![img_2.png](../images/消费模型.png)
 
 计算实例实质上是依赖了Rocket-streams SDK的client，因此，计算实例消费的MQ依赖RocketMQ rebalance分配，
 计算实例总个数也不能大于消费总MQ个数，否则将有部分计算实例处于等待状态，消费不到数据。
@@ -17,16 +17,16 @@ shuffle topic消费。如果还涉及count之类有状态算子，那么计算
 一个计算实例可以消费多个MQ，一个实例内也只有一张计算拓扑图。
 
 ### 状态
-![img_3.png](../images/状态.png)
+![img_3.png](../images/状态存储.png)
 
-对于有状态算子，他的状态本地依赖RocksDB加速读取，远程依赖Mysql做持久化。允许流计算任务时，可以只依赖本地存储
+对于有状态算子，他的状态本地依赖RocksDB加速读取，远程依赖RocketMQ做持久化。允许流计算任务时，可以只依赖本地存储
 RocksDB, 只需要将setLocalStorageOnly设置成true即可。这种情况下可能存在状态丢失。
 
 
 
 ### 扩缩容
 
-![img.png](../images/缩容.png)
+![img.png](../images/RocketMQ-streams扩缩容.png)
 
 当计算实例从3个缩容到2个，借助于RocketMQ的rebalance，MQ会在计算实例之间重新分配。
 Instance1上消费的MQ2和MQ3被分配到Instance2和Instance3上，这两个MQ的状态数据也需要迁移到Instance2
diff --git "a/docs/images/RocketMQ-streams\346\211\251\347\274\251\345\256\271.png" "b/docs/images/RocketMQ-streams\346\211\251\347\274\251\345\256\271.png"
new file mode 100644
index 00000000..585f5ce4
Binary files /dev/null and "b/docs/images/RocketMQ-streams\346\211\251\347\274\251\345\256\271.png" differ
diff --git a/docs/images/logo.jpeg b/docs/images/logo.jpeg
deleted file mode 100644
index 71f132c6..00000000
Binary files a/docs/images/logo.jpeg and /dev/null differ
diff --git "a/docs/images/\346\211\251\345\256\271\345\211\215.png" "b/docs/images/\346\211\251\345\256\271\345\211\215.png"
deleted file mode 100644
index 5232b762..00000000
Binary files "a/docs/images/\346\211\251\345\256\271\345\211\215.png" and /dev/null differ
diff --git "a/docs/images/\346\211\251\347\274\251\345\256\271.png" "b/docs/images/\346\211\251\347\274\251\345\256\271.png"
new file mode 100644
index 00000000..9104e278
Binary files /dev/null and "b/docs/images/\346\211\251\347\274\251\345\256\271.png" differ
diff --git "a/docs/images/\346\266\210\350\264\271\346\250\241\345\236\213.png" "b/docs/images/\346\266\210\350\264\271\346\250\241\345\236\213.png"
new file mode 100644
index 00000000..05f82574
Binary files /dev/null and "b/docs/images/\346\266\210\350\264\271\346\250\241\345\236\213.png" differ
diff --git "a/docs/images/\347\212\266\346\200\201.png" "b/docs/images/\347\212\266\346\200\201.png"
deleted file mode 100644
index e2fd9b2e..00000000
Binary files "a/docs/images/\347\212\266\346\200\201.png" and /dev/null differ
diff --git "a/docs/images/\347\212\266\346\200\201\345\255\230\345\202\250.png" "b/docs/images/\347\212\266\346\200\201\345\255\230\345\202\250.png"
new file mode 100644
index 00000000..9afe5afa
Binary files /dev/null and "b/docs/images/\347\212\266\346\200\201\345\255\230\345\202\250.png" differ
diff --git "a/docs/images/\347\274\251\345\256\271.png" "b/docs/images/\347\274\251\345\256\271.png"
deleted file mode 100644
index 05dcee41..00000000
Binary files "a/docs/images/\347\274\251\345\256\271.png" and /dev/null differ