Several questions:

1. Is there any way to set the log level for the Java workers via a Python
Dataflow pipeline?

2. What is the easiest way to debug an external transform in Java? My main
pipeline code is in Python.

3. Are there any edge cases with the UnboundedSourceWrapperFn SDF that I
should be wary of? I'm currently encountering a odd case (in Dataflow)
where a Java pipeline runs with only one worker all the way reading Solace
messages, but with an external transform in Python, it generates a large
number of consumers and stop reading messages altogether about 90% of the
way.

Thanks!

Cheers
Alex

Reply via email to