Parallel Processing using Expansions Before you begin Create Jobs based on a template Create manifests from the template Create Jobs from the manifests Clean up Use advanced t...

命令行界面 Job Lifecycle Management Submitting a Job Job Monitoring Creating a Savepoint Disposing a Savepoint Terminating a Job Stopping a Job Gracefully Creating a Final Savepoint...

Jobs 运行示例 Job 编写 Job 规约 Pod 模版 Pod 选择算符 Job 的并行执行 控制并行性 处理 Pod 和容器失效 Pod 回退失效策略 Job 终止与清理 自动清理完成的 Job 已完成 Job 的 TTL 机制 Job 模式 高级用法 指定你自己的 Pod 选择算符 替代方案 裸 Pod 副本控制器 ...

Job Service Architecture Overview Different Types of Jobs Load Migrate Persist Evict Move Replicate Data Transformation Inspection Commands fsadmin report jobservice ...

Flink 运维操场 Anatomy of this Playground Starting the Playground Entering the Playground Flink WebUI Logs Flink CLI Flink REST API Kafka Topics Time to Play! Listing Running J...

Flink Operations Playground Anatomy of this Playground Starting the Playground Entering the Playground Flink WebUI Logs Flink CLI Flink REST API Kafka Topics Time to Play! ...

Transforms APIs Create a transform job Request format Path parameters Request body fields Sample Request Sample Response Update a transform job Request format Query paramete...

Index rollups API Table of contents Create or update an index rollup job Request Sample response Get an index rollup job Request Sample response Delete an index rollup job ...

使用工作队列进行粗粒度并行处理 准备开始 启动消息队列服务 测试消息队列服务 为队列增加任务 创建镜像 定义 Job 运行 Job 替代方案 友情提醒 使用工作队列进行粗粒度并行处理 本例中，我们会运行包含多个并行工作进程的 Kubernetes Job。 本例中，每个 Pod 一旦被创建，会立即从任务队列中取走一个工作单元并完成...