Hi, I was wondering whether it is possible to stop streaming data in from one of the map operators until some data arrives in the second map operator.
For ex, if i have ds1.connect(ds2).map(new coflatmapper()) then, i need data to stop flowing from ds1 until some data arrives in ds2. Is that possible? I know that's a problematic situation as ds1 may get overwhelmed with data if not processed quickly, but any work around would really helpful. I was thinking of busy waiting, but I doubt that, the 2 maps work in different threads. Regards Biplob -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Way-to-hold-execution-of-one-of-the-map-operator-in-Co-FlatMaps-tp7689.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
