Caused by: java.lang.RuntimeException: Record has Long.MIN_VALUE timestamp (= no timestamp marker). Is the time characteristic set to 'ProcessingTime', or did you forget to call 'DataStream.assignTimestampsAndWatermarks(...)'?
解决方案:
在声明 Flink 环境时,设置时间语义
//需要设置时间语义 env.setStreamTimeCharacteristic(TimeCharacteristic.ProcessingTime);
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)