如标题:在scala->stream->LateDataSideOut侧输出这个例子中 reduceData.print() 和 reduceData.getSideOutput(lateOutputTag).print()没有输出结果。但是我在reduce方法中println是可以的,以及将 .allowedLateness(Time.seconds(10)) 和.sideOutputLateData(lateOutputTag)这两个方法注释之后是可以的,kafaka的数据(用的是上一个版本的例子)如下:
{"number":"5","name":"aaaa5","time":1579598108768}
{"number":"3","name":"aaaa3","time":1579598108768}
{"number":"5","name":"aaaa5","time":1579598108768}
如标题:在scala->stream->LateDataSideOut侧输出这个例子中 reduceData.print() 和 reduceData.getSideOutput(lateOutputTag).print()没有输出结果。但是我在reduce方法中println是可以的,以及将 .allowedLateness(Time.seconds(10)) 和.sideOutputLateData(lateOutputTag)这两个方法注释之后是可以的,kafaka的数据(用的是上一个版本的例子)如下:
{"number":"5","name":"aaaa5","time":1579598108768}
{"number":"3","name":"aaaa3","time":1579598108768}
{"number":"5","name":"aaaa5","time":1579598108768}