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