refactor window operator and internal state management
update state manager
fix kafka producer bug
Merge remote-tracking branch 'upstream/master'
update kafka producer
add disk dump sink, prepare to support multiple output stream
merge stage 1
merge
Merge branch 'Frank-Wu-master'
merge