setStreamTimeCharacteristic 1.12版本已经是标记弃用了

Question

setStreamTimeCharacteristic 1.12版本已经是标记弃用了。
没看懂官方文档，换成了什么

Answer 1

Michael_PK 2021-04-25 23:51:24

新的版本默认不需要设置了

• 提问者 bking3629688 #1

  data.flatMap(_.split(","))
      .map((_,1))
      .keyBy(0)
      .timeWindow(Time.seconds(5))
      .sum(1)
      .print()
      .setParallelism(1)
  
  但是不设置，新版本执行上面那段会报错
  Record has Long.MIN_VALUE timestamp (= no timestamp marker). Is the time characteristic set to 'ProcessingTime', or did you forget to call 'DataStream.assignTimestampsAndWatermarks(...)'?
  
  是指要生成水印吗

• Michael_PK 回复 提问者 bking3629688 #2

  1.12版本的flink，setStreamTimeCharacteristic 这个不需要设置，默认就是eventtime，所以你的data必须要使用assignTimestampsAndWatermarks提取出wm所需要的时间字段

• 提问者 bking3629688 回复 Michael_PK #3

  好的，谢谢PK老师。我继续往后面学水印部分