private void insertJVMAargs ( ) { final String flowName = this . node . getParentFlow ( ) . getFlowId ( ) ; final String jobId = this . node . getId ( ) ; String jobJVMArgs = String . format ( "'-Dazkaban.flowid=%s' '-Dazkaban.execid=%s' '-Dazkaban.jobid=%s'" , flowName , this . executionId , jobId ) ; final String previousJVMArgs = this . props . get ( JavaProcessJob . JVM_PARAMS ) ; jobJVMArgs += ( previousJVMArgs == null ) ? "" : " " + previousJVMArgs ; this . logger . info ( "job JVM args: " + jobJVMArgs ) ; this . props . put ( JavaProcessJob . JVM_PARAMS , jobJVMArgs ) ; }
Add useful JVM arguments so it is easier to map a running Java process to a flow execution id and job