Thanks Matthias. Disabling the cache didn't solve the issue. Here's a sample code:
https://gist.github.com/hrafzali/c2f50e7b957030dab13693eec1e49c13 The topology doesn't produce any result but it works when commenting out .map(...) in line 21. Thanks, Hamid
