Code review changes

hpcc-systems · Sep 5, 2023 · bd04aff · bd04aff
1 parent fa60891
commit bd04aff
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/dfsclient/src/main/java/org/hpccsystems/dfs/client/HPCCRemoteFileWriter.java b/dfsclient/src/main/java/org/hpccsystems/dfs/client/HPCCRemoteFileWriter.java
@@ -89,8 +89,8 @@ public HPCCRemoteFileWriter(DataPartition dp, FieldDef recordDef, IRecordAccesso
         this.binaryRecordWriter.initialize(this.recordAccessor);
 
         log.info("HPCCRemoteFileWriter: Opening file part: " + dataPartition.getThisPart()
-                + " compression: " + fileCompression.name() + " "
-                + " record definition:\n"
+                + " compression: " + fileCompression.name());
+        log.trace("Record definition:\n"
                 + RecordDefinitionTranslator.toJsonRecord(this.recordDef));
         openTimeMs = System.currentTimeMillis();
     }

diff --git a/dfsclient/src/main/java/org/hpccsystems/dfs/client/HpccRemoteFileReader.java b/dfsclient/src/main/java/org/hpccsystems/dfs/client/HpccRemoteFileReader.java
@@ -207,8 +207,8 @@ public HpccRemoteFileReader(DataPartition dp, FieldDef originalRD, IRecordBuilde
 
 
         log.info("HPCCRemoteFileReader: Opening file part: " + dataPartition.getThisPart()
-                + (resumeInfo != null ? " resume position: " + resumeInfo.inputStreamPos : "" )
-                + " original record definition:\n"
+                + (resumeInfo != null ? " resume position: " + resumeInfo.inputStreamPos : "" ));
+        log.trace("Original record definition:\n"
                 + RecordDefinitionTranslator.toJsonRecord(originalRD)
                 + " projected record definition:\n"
                 + RecordDefinitionTranslator.toJsonRecord(projectedRecordDefinition));