Flink16:Flink知识点

Flink16:Flink知识点

引入依赖

  • flink-java
  • flink-client
  • flink-streaming-java

并行度Parallelism 与Slot

parallelism path 三个地方可以设置
  • 应用程序代码
  • 页面设置
 
 
task slot设置
  • standalone模式,需要一直等待足够的slot满足并行度parallelism
 
 

开窗Window

 
 
按每日进行聚合
当日的起点
当日的数据
 
偏移量
偏移方式