revise flume script