Flink is a powerful high-performance distributed stream processing engine,More information about it you can,You can search for Apache Flink

Begin with flink.

Example: I set a precise Checkpoint for this job

  1. env {
  2.   parallelism = 1  
  3.   flink.execution.checkpointing.unaligned.enabled=true
  4. }

Enumeration types are not currently supported, you need to specify them in the Flink conf file ,Only these types of Settings are supported for the time being:
Integer/Boolean/String/Duration

This is a simple job that runs on Flink Randomly generated data is printed to the console

  1. env {
  2.   # common parameter
  3.   parallelism = 1
  4.   checkpoint.interval = 5000
  6.   # flink special parameter
  7.   flink.execution.checkpointing.mode = "EXACTLY_ONCE"
  8.   flink.execution.checkpointing.timeout = 600000
  9. }
  11. source {
  12.   FakeSource {
  13.     row.num = 16
  14.     result_table_name = "fake_table"
  15.     schema = {
  16.       fields {
  17.         c_map = "map<string, string>"
  18.         c_array = "array<int>"
  19.         c_string = string
  20.         c_boolean = boolean
  21.         c_int = int
  22.         c_bigint = bigint
  23.         c_double = double
  24.         c_bytes = bytes
  25.         c_date = date
  26.         c_decimal = "decimal(33, 18)"
  27.         c_timestamp = timestamp
  28.         c_row = {
  29.           c_map = "map<string, string>"
  30.           c_array = "array<int>"
  31.           c_string = string
  32.           c_boolean = boolean
  33.           c_int = int
  34.           c_bigint = bigint
  35.           c_double = double
  36.           c_bytes = bytes
  37.           c_date = date
  38.           c_decimal = "decimal(33, 18)"
  39.           c_timestamp = timestamp
  40.         }
  41.       }
  42.     }
  43.   }
  44. }
  46. transform {
  47.   # If you would like to get more information about how to configure seatunnel and see full list of transform plugins,
  48.   # please go to https://seatunnel.apache.org/docs/transform-v2/sql
  49. }
  51. sink{
  52.    Console{}   
  53. }

How to run a job in a project

After you pull the code to the local, go to the seatunnel-examples/seatunnel-flink-connector-v2-example module find org.apache.seatunnel.example.flink.v2.SeaTunnelApiExample To complete the operation of the job