diff --git a/nifi-custom-controllers/src/main/java/io/datadynamics/nifi/record/parquet/WriteParquetResult.java b/nifi-custom-controllers/src/main/java/io/datadynamics/nifi/record/parquet/WriteParquetResult.java
index 30c8929..1d71b14 100644
--- a/nifi-custom-controllers/src/main/java/io/datadynamics/nifi/record/parquet/WriteParquetResult.java
+++ b/nifi-custom-controllers/src/main/java/io/datadynamics/nifi/record/parquet/WriteParquetResult.java
@@ -45,19 +45,20 @@ public WriteParquetResult(final Schema avroSchema, final RecordSchema recordSche
         ParquetUtils.applyCommonConfig(writerBuilder, conf, parquetConfig);
         parquetWriter = writerBuilder.build();
 
-        if (componentLogger.isInfoEnabled()) { // FIXED
-            componentLogger.info("[DFM] WriteParquetResult : Schema = {}", schema);
-            componentLogger.info("[DFM] WriteParquetResult : timestampFormatPropertyKeyName = {}, addHours = {}", this.timestampFormatPropertyKeyName, this.addHours);
+        if (componentLogger.isDebugEnabled()) {
+            componentLogger.debug("[DFM] WriteParquetResult : Schema = {}", schema);
+            componentLogger.debug("[DFM] WriteParquetResult : timestampFormatPropertyKeyName = {}, addHours = {}", this.timestampFormatPropertyKeyName, this.addHours);
         }
     }
 
     @Override
     protected Map<String, String> writeRecord(final Record record) throws IOException {
-        if (componentLogger.isInfoEnabled()) {
-            this.componentLogger.info("[DFM] [Write] Record = {}", record);
+        if (componentLogger.isDebugEnabled()) {
+            this.componentLogger.debug("[DFM] [Write] Record = {}", record);
         }
 
         final GenericRecord genericRecord = AvroTypeUtil.createAvroRecord(record, schema, timestampFormatPropertyKeyName, addHours);
+        parquetWriter.write(genericRecord);
         return Collections.emptyMap();
     }
 
@@ -81,5 +82,4 @@ public String getMimeType() {
         return "application/parquet";
     }
 
-}
-
+}
\ No newline at end of file