flink 1.13.2 的sql connector写入 mongo

在 Flink 1.13.2 中，可以使用 Flink SQL Client 或 Flink SQL API 将数据写入 MongoDB。以下是使用 Flink SQL Client 将数据写入 MongoDB 的步骤：

1. 启动 Flink SQL Client。可以使用以下命令启动：

   ./bin/sql-client.sh embedded -e "flink:jobmanager:localhost:8081"

2. 创建一个 MongoDB 表：

   CREATE TABLE mongo_table (
       id INT,
       name STRING,
       age INT,
       PRIMARY KEY (id) NOT ENFORCED
   ) WITH (
       'connector' = 'mongodb',
       'hosts' = 'localhost:27017',
       'database' = 'test',
       'collection' = 'flink_table'
   );

3. 将数据插入到表中：

   INSERT INTO mongo_table VALUES (1, 'Alice', 20), (2, 'Bob', 25);

这样就可以将数据写入到 MongoDB 中了。需要注意的是，Flink SQL Connector for MongoDB 目前仍处于实验阶段，可能存在一些限制和不稳定性。