added StreamExecutionEnvironment on FlinkTopology