fixed log messages

pravega · Feb 6, 2024 · 3e1af42 · 3e1af42
1 parent a2ddf24
commit 3e1af42
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...llector/src/main/java/io/pravega/sensor/collector/file/parquet/ParquetEventGenerator.java b/...llector/src/main/java/io/pravega/sensor/collector/file/parquet/ParquetEventGenerator.java
@@ -123,11 +123,12 @@ public Pair<Long, Long> generateEventsFromInputStream(CountingInputStream inputS
             parquetSchemas.put(schema, avroSchema);
         }
         else{
+            LOGGER.debug("Retrieving cached schema");
             avroSchema = parquetSchemas.get(schema);
         }
 
         double elapsedSec1 = (System.nanoTime() - timestamp1) / 1_000_000_000.0;
-        log.info("Time taken to process schema= {} sec ", elapsedSec1);
+        LOGGER.debug("Time taken to process schema= {} sec ", elapsedSec1);
         long timestamp2 = System.nanoTime();
 
         final AvroParquetReader.Builder<GenericRecord> builder = AvroParquetReader.<GenericRecord>builder(tempFilePath);
@@ -162,7 +163,7 @@ public Pair<Long, Long> generateEventsFromInputStream(CountingInputStream inputS
             nextSequenceNumber++;
         }
         double elapsedSec2 = (System.nanoTime() - timestamp2) / 1_000_000_000.0;
-        log.info("Time taken to read records and batch events= {} sec ", elapsedSec2);
+        LOGGER.info("Time taken to read records and batch events= {} sec ", elapsedSec2);
         final long endOffset = inputStream.getCount();
         reader.close();
         tempFile.delete();