【问题】).想知道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是怎遍历顺序的?      
-------------------             

回复