flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Márton Balassi <balassi.mar...@gmail.com>
Subject Re: Streaming Exception error message Explanation
Date Thu, 07 Jul 2016 09:24:38 GMT
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 <yasubash@gmail.com> wrote:

> loop

Mime
View raw message