Hi all, I have very trivial use case where I have a

SingleOutputStreamOperator<Integer>

stream with only

1  value.

I need to extract the value and

store it in any dataType

. I have tried with

executeAndCollect and collectAsync(collector).

Is there any trivial way to do it Or am I going in wrong direction?

FileSystem is our Source and Sink

. I have one batch stream, After doing some aggregation on it there is only 1 aggregated value present in it. I have to return this value in the headers in TextFile. Below is the implementation I have tried ,

CloseableIterator<Integer> jobExecutionIterator = singleOutputStreamOperator.executeAndCollect("Aggregate Calculator- Avg"));
Integer value = jobExecutionIterator.next();

This Implementation gives me this error

Job client must be a Coordination Request Gateway