Hi all,
I would like to use the streaming engine in my project to see if performance 
improves.
in order to that I upgraded my project dependencies from 
google-cloud-dataflow-java-sdk-all 2.5.0 to beam-sdks-java-core 2.12.0. I also 
added a dependency from beam-runners-google-cloud-dataflow-java.
Code was unchanged.
Unfortunately this doesn't seem to work. Also a very simple pipeline reading 
from a bucket and writing in BigTable hangs not showing any element added and 
not writing any log line.

Thanks

Reply via email to