#NEWLINE# @ raises ( HdfsError ) #NEWLINE# def test_write_overwrite_error( self ) : #NEWLINE# #INDENT# self . client . makedirs ( 'weather.avro' ) #NEWLINE# with AvroWriter ( self . client , 'weather.avro' , schema = self . schema ) as writer : #NEWLINE# #INDENT# for record in self . records : #NEWLINE# #INDENT# writer . write ( record )