Hi, you just need to terminate your source (ie, return from run() method if you implement your own source function). This will finish the complete program. For already available sources, just make sure you read finite input.
Hope this helps.
-Matthias
On 10/05/2015 12:15 AM, jay vyas wrote:
> Hi folks.
>
> How do we end a stream execution environment?
>
> I have a unit test which runs a streaming job, and want the unit test to
> die after the first round of output is processed...
>
>
> DataStream<Tuple2<Map, Integer>> counts =
> dataStream.map(
> new MapFunction<String, Tuple2<Map, Integer>>() {
> @Override
> public Tuple2<Map, Integer> map(String s) throws Exception {
> Map transaction = MAPPER.readValue(s, Map.class);
> return new Tuple2<>(transaction, 1);
> }
> });
> counts.print();
>
>
>
> --
> jay vyas
signature.asc
Description: OpenPGP digital signature
