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() {
127
127
128
128
@ Override
129
129
public void abort () {
130
- Util .MAIN_LOGGER .warn ("Abort called; stopping job " );
130
+ Util .MAIN_LOGGER .warn ("Abort called. " );
131
131
stopJobAndRelease ();
132
132
closeArchiveWriter ();
133
- Util .MAIN_LOGGER .info ("Finished abort" );
133
+ Util .MAIN_LOGGER .info ("Finished abort. " );
134
134
}
135
135
136
136
@ Override
137
137
public void close () {
138
138
if (logger .isDebugEnabled ()) {
139
- logger .debug ("Close called; stopping job ." );
139
+ logger .debug ("Close called." );
140
140
}
141
141
stopJobAndRelease ();
142
142
closeArchiveWriter ();
Original file line number Diff line number Diff line change @@ -84,7 +84,7 @@ public void abort() {
84
84
@ Override
85
85
public void close () {
86
86
if (logger .isDebugEnabled ()) {
87
- logger .debug ("Close called; stopping job ." );
87
+ logger .debug ("Close called." );
88
88
}
89
89
if (databaseClient != null ) {
90
90
databaseClient .release ();
You can’t perform that action at this time.
0 commit comments