You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by fa...@apache.org on 2022/06/24 02:29:40 UTC
[incubator-seatunnel-website] branch main updated: Update 2022-05-31-engine.md (#134)
This is an automated email from the ASF dual-hosted git repository.
fanjia pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel-website.git
The following commit(s) were added to refs/heads/main by this push:
new 365de8e33 Update 2022-05-31-engine.md (#134)
365de8e33 is described below
commit 365de8e33cabc4867fe3a8ec93ef05f7a6cc29b1
Author: Jared Li <lh...@gmail.com>
AuthorDate: Fri Jun 24 10:29:36 2022 +0800
Update 2022-05-31-engine.md (#134)
Writer and Committer running on the worker(Job Manager).
->
Writer and Committer running on the worker(Task Manager).
---
blog/2022-05-31-engine.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/blog/2022-05-31-engine.md b/blog/2022-05-31-engine.md
index 7729db411..abd65a337 100644
--- a/blog/2022-05-31-engine.md
+++ b/blog/2022-05-31-engine.md
@@ -156,7 +156,7 @@ Based on these three requirements, we built three APIS: SinkWriter, SinkCommitte
Ideally, AggregatedCommitter runs in Driver in single or parallel, and Writer and Committer run in Worker with multiple parallels, with each parallel carrying its own pre-commit work and then send Aggregated messages to Aggregated committers.
-Current advanced versions of Spark and Flink all support AggregatedCommitter running on the Driver(Job Manager) and Writer and Committer running on the worker(Job Manager).
+Current advanced versions of Spark and Flink all support AggregatedCommitter running on the Driver(Job Manager) and Writer and Committer running on the worker(Task Manager).
