Step 1: Deployment SeaTunnel And Connectors

Before starting, make sure you have downloaded and deployed SeaTunnel as described in deployment

Please download Flink first(required version >= 1.12.0). For more information you could see Getting Started: standalone

Configure SeaTunnel: Change the setting in config/seatunnel-env.sh, it is base on the path your engine install at deployment. Change FLINK_HOME to the Flink deployment dir.

Step 3: Add Job Config File to define a job

Edit config/v2.streaming.conf.template, which determines the way and logic of data input, processing, and output after seatunnel is started. The following is an example of the configuration file, which is the same as the example application mentioned above.

  1. env {
  2.   parallelism = 1
  3.   job.mode = "BATCH"
  4. }
  6. source {
  7.   FakeSource {
  8.     result_table_name = "fake"
  9.     row.num = 16
  10.     schema = {
  11.       fields {
  12.         name = "string"
  13.         age = "int"
  14.       }
  15.     }
  16.   }
  17. }
  19. transform {
  20.   FieldMapper {
  21.     source_table_name = "fake"
  22.     result_table_name = "fake1"
  23.     field_mapper = {
  24.       age = age
  25.       name = new_name
  26.     }
  27.   }
  28. }
  30. sink {
  31.   Console {
  32.     source_table_name = "fake1"
  33.   }
  34. }

More information about config please check config concept

Step 4: Run SeaTunnel Application

You could start the application by the following commands

flink version between 1.12.x and 1.14.x

  1. cd "apache-seatunnel-${version}"
  2. ./bin/start-seatunnel-flink-13-connector-v2.sh --config ./config/v2.streaming.conf.template

flink version between 1.15.x and 1.16.x

  1. cd "apache-seatunnel-${version}"
  2. ./bin/start-seatunnel-flink-15-connector-v2.sh --config ./config/v2.streaming.conf.template

See The Output: When you run the command, you could see its output in your console. You can think this is a sign that the command ran successfully or not.

The SeaTunnel console will prints some logs as below:

  1. fields : name, age
  2. types : STRING, INT
  3. row=1 : elWaB, 1984352560
  4. row=2 : uAtnp, 762961563
  5. row=3 : TQEIB, 2042675010
  6. row=4 : DcFjo, 593971283
  7. row=5 : SenEb, 2099913608
  8. row=6 : DHjkg, 1928005856
  9. row=7 : eScCM, 526029657
  10. row=8 : sgOeE, 600878991
  11. row=9 : gwdvw, 1951126920
  12. row=10 : nSiKE, 488708928
  13. row=11 : xubpl, 1420202810
  14. row=12 : rHZqb, 331185742
  15. row=13 : rciGD, 1112878259
  16. row=14 : qLhdI, 1457046294
  17. row=15 : ZTkRx, 1240668386
  18. row=16 : SGZCr, 94186144

What’s More

For now, you are already take a quick look about SeaTunnel with Flink, you could see connector to find all source and sink SeaTunnel supported. Or see SeaTunnel With Flink if you want to know more about SeaTunnel Run With Flink.

SeaTunnel have an own engine named Zeta and Zeta is the default engine of SeaTunnel. You can follow Quick Start to configure and run a data synchronization job.