bugfix

diff --git a/wikiq b/wikiq
index d966b5062b38738e441952532daa8c625d7e128d..8c51979ca5b697c73a78525a2b1c4fb14a016229 100755 (executable)
--- a/wikiq
+++ b/wikiq
@@ -593,7 +593,7 @@ class WikiqParser():
             self.pq_writer = pq.ParquetWriter(self.output_file, schema, flavor='spark')
 
         self.pq_writer.write_table(outtable)
             self.pq_writer = pq.ParquetWriter(self.output_file, schema, flavor='spark')
 
         self.pq_writer.write_table(outtable)

-        self.output_buffer = []
+        self.parquet_buffer = []

         
     def print_rev_data(self, rev_data):
         if self.output_parquet is False:
         
     def print_rev_data(self, rev_data):
         if self.output_parquet is False: