【问题】).想知道local,flink
在window完成时,发送给sink的数据顺序,这个顺序是怎么确定的?-------------------).输入数据:1 2 1 3
2).程序:Flink 1.7.2 local wordCount, dataStream.timeWindow(Time.seconds(10))
).WindowOperator.onProcessingTime windowState.stateTable.primaryTable 数据结构
167 = {CopyOnWriteStateTable$StateTableEntry@7257}
"((1)|TimeWindow{start=1551500340000, end=1551500350000})=WordWithCount(1,2)"
419 = {CopyOnWriteStateTable$StateTableEntry@7258}
"((3)|TimeWindow{start=1551500340000, end=1551500350000})=WordWithCount(3,1)"
767 = {CopyOnWriteStateTable$StateTableEntry@7259}
"((2)|TimeWindow{start=1551500340000, end=1551500350000})=WordWithCount(2,2)"
). 发送给sink时 发送的顺序是: WordWithCount(1,2) WordWithCount(3,1)
WordWithCount(2,2) ??问题是,这个顺序是怎么确定的? ).keyContext.getCurrentKey() 的顺序是
1 3 2 keyContext.getCurrentKey() 这个key是怎遍历顺序的?
-------------------