@Test
public void testWorkflowIdTag() {

  Props props = new Props();
  props.put(CommonJobProperties.EXEC_ID, "123");
  props.put(CommonJobProperties.PROJECT_NAME, "project-name");
  props.put(CommonJobProperties.FLOW_ID, "flow-id");
  AbstractHadoopJavaProcessJob job = new AbstractHadoopJavaProcessJob("test", new Props(), props, null) {};
  job.setupHadoopJobProperties();
  assertThat(job.getJobProps().get(HadoopConfigurationInjector.INJECT_PREFIX + HadoopJobUtils.MAPREDUCE_JOB_TAGS))
      .isEqualTo("azkaban.flow.execid:123,azkaban.flow.flowid:flow-id"
          + ",azkaban.flow.projectname:project-name,workflowid:project-name$flow-id");
}