def _log_record_from_hadoop(record):
 if (not _is_counter_log4j_record(record)):
  level = getattr(logging, (record.get('level') or ''), None)
  _log_line_from_hadoop(record['message'], level=level)

def _log_record_from_hadoop ( record ) : if ( not _is_counter_log4j_record ( record ) ) : level = getattr ( logging , ( record . get ( 'level' ) or '' ) , None ) _log_line_from_hadoop ( record [ 'message' ] , level = level )
log log4j record parsed from hadoop stderr .