File tree Expand file tree Collapse file tree 1 file changed +7
-3
lines changed
marklogic-client-api/src/main/java/com/marklogic/client/datamovement/impl Expand file tree Collapse file tree 1 file changed +7
-3
lines changed Original file line number Diff line number Diff line change @@ -185,8 +185,10 @@ public void initialize() {
185185
186186 initialized = true ;
187187
188- logger .info ("threadCount={}" , getThreadCount ());
189- logger .info ("batchSize={}" , getBatchSize ());
188+ if (logger .isDebugEnabled ()) {
189+ logger .debug ("threadCount={}" , getThreadCount ());
190+ logger .debug ("batchSize={}" , getBatchSize ());
191+ }
190192 super .setJobStartTime ();
191193 super .getStarted ().set (true );
192194 }
@@ -397,7 +399,9 @@ private void flush(boolean waitForCompletion) {
397399 List <DocumentWriteOperation > docs = new ArrayList <>();
398400 batchCounter .set (0 );
399401 queue .drainTo (docs );
400- logger .info ("flushing {} queued docs" , docs .size ());
402+ if (logger .isTraceEnabled ()) {
403+ logger .trace ("flushing {} queued docs" , docs .size ());
404+ }
401405 Iterator <DocumentWriteOperation > iter = docs .iterator ();
402406 for ( int i =0 ; iter .hasNext (); i ++ ) {
403407 if ( isStopped () == true ) {
You can’t perform that action at this time.
0 commit comments