Great, thank you so much!
On Tue, Mar 9, 2021 at 1:08 PM Till Rohrmann wrote:
> *This message originated outside your organization.*
>
> --
>
> Hi Bob,
>
> Thanks for reporting this issue. I believe that this has been an
> oversight. I have filed a JIRA issue for fixi
Hi Bob,
Thanks for reporting this issue. I believe that this has been an oversight.
I have filed a JIRA issue for fixing this problem [1].
[1] https://issues.apache.org/jira/browse/FLINK-21693
Cheers,
Till
On Mon, Mar 8, 2021 at 4:15 PM Bob Tiernay wrote:
> Hi all,
>
> I have been trying to t
Hi all,
I have been trying to test a Flink 1.11 streaming job using the
`DataStreamUtils#collect` utility against a `MiniCluster` based test.
However, I noticed an issue when doing so.
`TestStreamEnvironment` does not implement `executeAsync`. Thus
when `DataStreamUtils#collect` is called, it inv
