[streaming] connectors logging and deploy update
[streaming] reduce operator added to DataStream and ConnectedDataStream + grouped batch and windowReduce operators reworked