William Guo

Source Code Analysis of Apache SeaTunnel Zeta Engine (Part 3): Server-Side Task Submission | HackerNoon

This is the last piece of the series articles to analyze the Apache SeaTunnel Zeta Engine Source Code; review the previous series to get the full picture: Let’s review the components that execute after the server starts: CoordinatorService: Enabled only on master/standby nodes, listens to cluster status, and handles master-standby failovers. SlotService: Enabled on worker nodes, periodically reports its status to the master. TaskExecutionService: Enabled on worker nodes, periodically updates task metrics to IMAP. When

Read More »

Source Code Analysis of Apache SeaTunnel Zeta Engine (Part 2): Task Submission Process on the Client Side | HackerNoon

Continuing from the previous article, Source Code Analysis of Apache SeaTunnel Zeta Engine (Part 1): Server Initialization Task Submission on the Client Side In this section, we will explain the task submission process in Apache SeaTunnel using the command-line interface (CLI). To submit a task using the CLI, the command is: ./bin/seatunnel.sh -c <config_path> When we check this script file, we see it ultimately calls the org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient class. public class SeaTunnelClient { public static void main(String[]

Read More »