1.flink任务各个算子的并行度一般怎么设计？例如map并行度设为多少，source并行度设为多少，这个有没有一个算法。
2.taskmanager的slot用完才会分配task到下一个taskmanager，这个设计初衷是如下原因吗？
摘自官网:
通过调整 slot 的数量，用户可以决定 subtasks 的隔离方式。每个 TaskManager 有一个 slot 意味着每组 task 在一个单独的 JVM 中运行（例如，在一个单独的容器中启动）。拥有多个 slots 意味着多个 subtasks 共享同一个 JVM。 Tasks 在同一个 JVM 中共享 TCP 连接（通过多路复用技术）和心跳信息（heartbeat messages）。它们还可能共享数据集和数据结构，从而降低每个 task 的开销。
[hidden email]
Locked
