Constant STATELESS_FLOW_QUERY_ERROR 

const STATELESS_FLOW_QUERY_ERROR: &str = "flow streaming supports only stateless projection/filter queries over one source";