flink

怎样实现并行计算？
  
并行的任务，需要占用多少的slot？
  并行需要单独的资源，当前任务的子任务都应该分配给不同的slot里
一个流处理程序，到底包含多少个任务？
  并行度（Parallelism)
  一个特定算子的子任务subtask的个数被称之为并行杜（parallelism)
  一般情况下，一个stream的并行杜，可以认为就是其所有算子中最大的并行度
 
 Source-> map（）->keyBy()/ window()/apply()->Sink
TaskManager和Slots的:
   Flink中的每一个TaskManager都是一个JVM进程，它可能会在独立的线程上执行一个或多个子任务
   为了控制一个TaskManager能接收多少个task,TaskManager通过task slot来进行控制（一个TaskManager至少有一个slot)