Cache the executor pointer in the StreamPool at construction time.  Otherwise there could potentially be streams from difference executors cached in the same pool.
Cache the executor pointer in the StreamPool at construction time.  Otherwise there could potentially be streams from difference executors cached in the same pool.
