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 <[email protected]>
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).
