#!/bin/bash

########################################

Flink + Doris 最小测试脚本（自动生成 10000 条数据）

测试 Flink 1.18 + Doris 3.x 插入数据

########################################

FLINK_HOME=/opt/flink/flink-1.18.1
JOB_NAME="flink_doris_minimal_test"

Doris 配置

DORIS_FE=172.16.24.171:9030 # Doris FE IP + SQL端口
DORIS_DB=demo # Doris 数据库
DORIS_TABLE=test_flink # Doris 表
DORIS_USER=test
DORIS_PASS='P@ssw0rd!'

临时 SQL 文件

SQL_FILE=/tmp/${JOB_NAME}.sql

echo ">>> 生成 Flink SQL 文件: ${SQL_FILE}"

生成 SQL 文件

cat > ${SQL_FILE} <<EOF
-- Flink SQL 设置（必须用引号）
SET 'execution.checkpointing.interval' = '10s';
SET 'parallelism.default' = '1';

-- Doris Sink 表（只定义列，不写主键，表在 Doris 已建）
CREATE TABLE doris_test (
id STRING,
name STRING
) WITH (
'connector' = 'doris',
'fenodes' = '${DORIS_FE}',
'table.identifier' = '${DORIS_DB}.${DORIS_TABLE}',
'username' = '${DORIS_USER}',
'password' = '${DORIS_PASS}',
'sink.label-prefix' = 'flink_test',
'sink.buffer-flush.max-rows' = '10000',
'sink.buffer-flush.interval' = '20s',
'sink.max-retries' = '5',
'sink.enable-delete' = 'false'
);

-- 测试插入至少 10000 条数据，保证 Connector flush
INSERT INTO doris_test VALUES
EOF

用循环生成 10000 条测试数据

for i in $(seq 1 10); do
if [ $i -lt 10 ]; then
echo "('$i','test_name$i')," >> ${SQL_FILE}
else
echo "('$i','test_name$i');" >> ${SQL_FILE}
fi
done

echo ">>> 提交 Flink SQL Client..."

提交 Flink SQL Client 执行

${FLINK_HOME}/bin/sql-client.sh -f ${SQL_FILE}

echo ">>> Flink Doris 最小测试任务已提交 ✅"

用户名密码都是对的，为什么一直提示无法从doris 获得响应