File tree Expand file tree Collapse file tree 2 files changed +4
-4
lines changed
src/main/java/com/marklogic/spark/writer Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -127,16 +127,16 @@ public WriterCommitMessage commit() {
127127
128128 @ Override
129129 public void abort () {
130- Util .MAIN_LOGGER .warn ("Abort called; stopping job " );
130+ Util .MAIN_LOGGER .warn ("Abort called. " );
131131 stopJobAndRelease ();
132132 closeArchiveWriter ();
133- Util .MAIN_LOGGER .info ("Finished abort" );
133+ Util .MAIN_LOGGER .info ("Finished abort. " );
134134 }
135135
136136 @ Override
137137 public void close () {
138138 if (logger .isDebugEnabled ()) {
139- logger .debug ("Close called; stopping job ." );
139+ logger .debug ("Close called." );
140140 }
141141 stopJobAndRelease ();
142142 closeArchiveWriter ();
Original file line number Diff line number Diff line change @@ -84,7 +84,7 @@ public void abort() {
8484 @ Override
8585 public void close () {
8686 if (logger .isDebugEnabled ()) {
87- logger .debug ("Close called; stopping job ." );
87+ logger .debug ("Close called." );
8888 }
8989 if (databaseClient != null ) {
9090 databaseClient .release ();
You can’t perform that action at this time.
0 commit comments