Deployment

    you need to set up Flink Environment.

    • InLong Sort file, apache-inlong-[version]-bin.tar.gz
    • Data Nodes Connectors, Download apache-inlong-{version}-sort-connectors.tar.gz

    Notice: Please put required Connectors jars into under FLINK_HOME/lib/ after download.

    We can write following SQL script if we want to read data from MySQL and write into PostgreSQL.

    1.  CREATE TABLE `table_1`(
    2.     `age` INT,
    3.     `name` STRING)
    4.     WITH (
    6.     'username' = 'root',
    7.     'password' = 'inlong',
    8.     'database-name' = 'test',
    9.     'scan.incremental.snapshot.enabled' = 'false',
    10.     'server-time-zone' = 'GMT+8',
    11.     'table-name' = 'user'
    12. );
    13. CREATE TABLE `table_2`(
    14.     PRIMARY KEY (`name`) NOT ENFORCED,
    15.     `name` STRING,
    17.     'connector' = 'jdbc',
    18.     'url' = 'jdbc:postgresql://localhost:5432/postgres',
    19.     'username' = 'postgres',
    20.     'password' = 'inlong',
    21.     'table-name' = 'public.user',
    22.     'port' = '3306'
    23. );
    24. INSERT INTO `table_2` 
    25.     SELECT 
    26.     `name` AS `name`,