Flink拾遗

unin,join,connect

  • unin将同类型的流合并到一起,类似于汇聚
  • join 按照某种规则从两个流选择一部分数据
  • connect 将两个流(DataStream)连接到一起,此时生成的流(ConnectedStream)具备两个类型,可以应用算子处理,算子内部可以共享一部分数据结构与状态

物理分组

  • 如果上下游并行度一致,默认是forward

API原理

客户端操作

  • cancle命令不优雅停止,stop命令优雅停止,在配置了savepoint路径后会生成savepoint
  • modify -p [int]动态调整并行度,会在调整的时候生成savepoint