spark streaming integration flume
code adjust commit