Flink之前有很多历史任务，就是做数据打宽和打点的，这种任务默认是什么模式？

在将 Flink 任务从 YARN 的 Application 模式迁移到 Docker 容器中运行时，任务的提交模式会有所变化。以下是详细解答：

1. Flink 在 YARN 中的 Application 模式

在 YARN 的 Application 模式下，每次提交一个 Flink 应用程序时，都会启动一个独立的 Flink 集群，该集群与应用程序生命周期绑定。这种模式适合包含多个作业的应用程序，资源隔离性较好。

2. Flink 在 Docker 中的默认模式

当 Flink 任务迁移到 Docker 容器中运行时，默认的提交模式取决于容器化环境的配置和 Flink 的启动方式。通常情况下： - 如果直接使用 java -jar 命令运行 Flink 作业，则默认采用的是 Standalone 模式。 - 在 Standalone 模式下，Flink 作业运行在一个已经启动的 Flink 集群中，而不是像 YARN 的 Application 模式那样为每个作业单独启动集群。

3. Docker 容器中的 Flink 提交模式

在 Docker 容器中运行 Flink 任务时，常见的模式包括以下几种： - Session 模式：Flink 集群预先启动，多个作业共享同一个集群资源。这种方式类似于 YARN 的 Session 模式，适合短期作业。 - Per-Job 模式：每个作业启动一个独立的 Flink 集群，资源隔离性较好，但启动时间较长。 - Application 模式：类似于 YARN 的 Application 模式，每个应用程序启动一个独立的 Flink 集群。

如果使用 java -jar 命令直接运行 Flink 作业，且没有额外指定模式，则默认是 Standalone 模式，即作业运行在一个已经启动的 Flink 集群中。

4. 如何确认或修改提交模式

要确认或修改 Flink 任务在 Docker 容器中的提交模式，可以通过以下方式： - 检查启动命令：查看是否通过 flink run 或其他命令指定了 -t 参数（如 -t yarn-application 或 -t yarn-per-job）。 - 配置文件：检查 Flink 的配置文件（如 flink-conf.yaml），确认是否有相关模式的配置。 - 容器编排工具：如果使用 Kubernetes 等容器编排工具，可以通过 Deployment 或 Job 配置文件确认 Flink 的运行模式。

5. 重要提醒

• 资源隔离：在 Docker 容器中运行 Flink 任务时，建议根据业务需求选择合适的模式。如果需要资源隔离，可以选择 Per-Job 或 Application 模式。
• 性能调优：迁移后需要对任务进行性能验证，确保吞吐量和延迟满足业务需求。
• 数据一致性：迁移过程中，建议通过双跑验证的方式，确保新任务的数据产出与原有任务一致。

总结

在 Docker 容器中运行 Flink 任务时，如果使用 java -jar 命令直接运行，默认采用的是 Standalone 模式。如果需要其他模式（如 Per-Job 或 Application 模式），需要通过命令行参数或配置文件显式指定。