Hi everyone,
Is there any recommended way to upload a third party jar (runtime scope)
for expanding transform like KafkaIO.Read when using the python portable
runner? Thank you!

I tried --experiments=jar_packages=abc.jar,d.jar but just found those
artifacts in python harness with provision info, and the java harness just
uses the default environment for dependencies after expanding
transformation from the grpc server upon expansion jar for reading Kafka
messages.

Also noticed above option will be removed in the future then tried
--files_to_stage but this option only exists in Java SDK pipeline options.

-- 
Yours Sincerely
Kobe Feng

Reply via email to