Hi Subash, Unfortunately you can not reference a DataStream (loop) within a Flink operator. To handle both casual and feedback data I suggest using CoOperators. Have a look at this mockup I did some time ago for a conceptually similar problem. [1]
[1] https://github.com/streamline-eu/ML-Pipelines/blob/da1e5e15afe607b31eb17b11978482a558fe022a/flink-staging/flink-streaming-ml/src/main/scala/org/apache/flink/streaming/ml/LinearRegressionScala.scala On Wed, Jul 6, 2016 at 3:35 PM, subash basnet <yasub...@gmail.com> wrote: > loop
