FlinkSQL create new stream