跳到主要内容
版本：2.3.7

quick-start-flink

Flink Engine快速开始

步骤 1: 部署SeaTunnel及连接器​

在开始前，请确保您已经按照部署中的描述下载并部署了SeaTunnel。

请先下载Flink(需要版本 >= 1.12.0)。更多信息您可以查看入门: Standalone模式

配置SeaTunnel: 修改config/seatunnel-env.sh中的设置，将FLINK_HOME配置设置为Flink的部署目录。

步骤 3: 添加作业配置文件来定义作业​

编辑config/v2.streaming.conf.template，它决定了SeaTunnel启动后数据输入、处理和输出的方式及逻辑。 下面是配置文件的示例，它与上面提到的示例应用程序相同。

env {
  parallelism = 1
  job.mode = "BATCH"
}

source {
  FakeSource {
    result_table_name = "fake"
    row.num = 16
    schema = {
      fields {
        name = "string"
        age = "int"
      }
    }
  }
}

transform {
  FieldMapper {
    source_table_name = "fake"
    result_table_name = "fake1"
    field_mapper = {
      age = age
      name = new_name
    }
  }
}

sink {
  Console {
    source_table_name = "fake1"
  }
}

关于配置的更多信息请查看配置的基本概念

步骤 4: 运行SeaTunnel应用程序​

您可以通过以下命令启动应用程序：

Flink版本1.12.x到1.14.x

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

Flink版本1.15.x到1.16.x

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

查看输出: 当您运行该命令时，您可以在控制台中看到它的输出。您可以认为这是命令运行成功或失败的标志。

SeaTunnel控制台将会打印一些如下日志信息:

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

此外​

现在,您已经快速浏览了SeaTunnel使用Flink引擎的方式，可以通过在连接器中找到SeaTunnel所支持的所有sources和sinks。 如果您想要了解更多关于SeaTunnel运行在Flink上的信息，请参阅基于Flink的SeaTunnel。

SeaTunnel有内置的Zeta引擎，它是作为SeaTunnel的默认引擎。您可以参考快速开始配置和运行数据同步作业。