前提条件

使用 Flink 客户端前，请确认客户端环境已满足以下条件：

• 已安装与产品版本兼容的 Java 环境。

• 已获取 Flink 客户端目录或安装包。

• 已配置集群连接信息和认证信息。

• 如作业访问 HDFS、Kafka、数据库等外部系统，已准备对应连接器 JAR、配置文件和访问权限。

在公有云环境下，请通过管理平台页面确认Flink集群服务状态为“正常”或“运行中”。

提交 JAR 作业

./bin/flink run \
  --target yarn-application \
  -Djobmanager.memory.process.size=1024m \
  -Dtaskmanager.memory.process.size=4096m \
  -Dparallelism.default=4 \
  /path/to/flink-job.jar

查看作业

./bin/flink list

停止作业并触发 Savepoint

./bin/flink stop \
  --savepointPath /path/to/savepoints \
  <job_id>

取消作业

./bin/flink cancel <job_id>

使用 SQL Client

Flink SQL Client 可用于编写、调试和提交 SQL 作业。SQL Client 支持嵌入模式，也支持连接 SQL Gateway。

./bin/sql-client.sh
./bin/sql-client.sh gateway --endpoint <gateway_address>
SET 'execution.runtime-mode' = 'streaming';
SELECT *FROM example_source;