code: private void updatePrimaryKeyConfig(String srcColumnName, String tgtColumnName) {
      if (this.workUnitState.contains(ConfigurationKeys.EXTRACT_PRIMARY_KEY_FIELDS_KEY)) {
        String primarykey = this.workUnitState.getProp(ConfigurationKeys.EXTRACT_PRIMARY_KEY_FIELDS_KEY);
        this.workUnitState.setProp(ConfigurationKeys.EXTRACT_PRIMARY_KEY_FIELDS_KEY,
            primarykey.replaceAll(srcColumnName, tgtColumnName));
      }
    }
docs: Update primary key column property if there is an alias defined in query
  
  @param srcColumnName source column name
  @param tgtColumnName target column name