Skip to content

Commit 57ce0ea

Browse files
committed
apply suggestions
1 parent 187a809 commit 57ce0ea

File tree

1 file changed

+2
-1
lines changed
  • data-loader/core/src/main/java/com/scalar/db/dataloader/core/dataimport/processor

1 file changed

+2
-1
lines changed

data-loader/core/src/main/java/com/scalar/db/dataloader/core/dataimport/processor/ImportProcessor.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,7 @@
3232
import java.util.concurrent.Semaphore;
3333
import java.util.concurrent.TimeUnit;
3434
import java.util.concurrent.atomic.AtomicInteger;
35+
import javax.annotation.Nullable;
3536
import lombok.RequiredArgsConstructor;
3637
import org.slf4j.Logger;
3738
import org.slf4j.LoggerFactory;
@@ -354,7 +355,7 @@ private ImportTransactionBatchResult processTransactionBatch(
354355
*
355356
* @param transaction the {@link DistributedTransaction} to be aborted, may be null
356357
*/
357-
private void abortTransactionSafely(DistributedTransaction transaction) {
358+
private void abortTransactionSafely(@Nullable DistributedTransaction transaction) {
358359
try {
359360
if (transaction != null) {
360361
transaction.abort();

0 commit comments

Comments
 (0)