...

1. Add a Python PipelineOption that represents the corresponding Java PipelineOption available here. This can be simply added to your Python program that starts up the Beam job.

   
   

   Code Block
   language py
   class JavaLoggingOptions(PipelineOptions):   @classmethod   def _add_argparse_args(cls, parser):     parser.add_argument(         '--sdkHarnessLogLevelOverrides',         default={},         type=json.loads,         help=(           'Java log level overrides'))

   
   

2. Specify the additional PipelineOption as a parameter when running the Beam pipeline.

   Code Block
   language bash
   --sdkHarnessLogLevelOverrides "'{\"org.apache.kafka\":\"ERROR\"}"'

   
   

Debugging a Python Test that calls a Java transform

...