Thank you! that did it !
On Wed, May 8, 2019 at 5:42 PM Till Rohrmann wrote:
> *This Message originated outside your organization.*
> --
> Hi Avi,
>
> you need to complete the given resultFuture and not return a future. You
> can do this via resultFuture.complete(r).
Hi Avi,
you need to complete the given resultFuture and not return a future. You
can do this via resultFuture.complete(r).
Cheers,
Till
On Tue, May 7, 2019 at 8:30 PM Avi Levi wrote:
> Hi,
> We are using flink 1.8.0 (but the flowing also happens in 1.7.2) I tried
> very simple unordered async
Hi,
We are using flink 1.8.0 (but the flowing also happens in 1.7.2) I tried
very simple unordered async call
override def asyncInvoke(input: Foo, resultFuture: ResultFuture[ScoredFoo])
: Unit = {
val r = ScoredFoo(Foo("a"), 80)
Future.successful(r)
}
Running this stream seem to be stuck
