Ability to partition logs per pipeline

[Sumit Chawla (sumichaw)]

Hi All

Does beam provide any ability to streamline logs being generated from a  
pipeline.  How can we keep the logs from two pipelines separate so that its 
easy to debug the pipeline execution (something dynamic to automatically 
partition the logs per pipeline) ? Or would it be something attributable to 
runner’s (Flink?) code?


Thanks
Sumit