bad Thread.interrupted usage
diff --git a/jbatch/src/test/java/org/apache/batchee/spi/PersistenceManagerServiceTest.java b/jbatch/src/test/java/org/apache/batchee/spi/PersistenceManagerServiceTest.java
index 079565a..497b33a 100644
--- a/jbatch/src/test/java/org/apache/batchee/spi/PersistenceManagerServiceTest.java
+++ b/jbatch/src/test/java/org/apache/batchee/spi/PersistenceManagerServiceTest.java
@@ -81,7 +81,7 @@
// sanity checks we persisted data before deleting them
assertNotNull(service.getJobStatus(instance.getInstanceId()));
- assertNotNull(service.getJobInstanceIdByExecutionId(exec.getExecutionId()));
+ service.getJobInstanceIdByExecutionId(exec.getExecutionId());
assertNotNull(service.jobOperatorGetJobExecution(exec.getExecutionId()));
assertNotNull(service.getStepExecutionByStepExecutionId(step.getStepExecutionId()));
assertNotNull(service.getCheckpointData(new CheckpointDataKey(instance.getInstanceId(), "step", CheckpointType.READER)));
@@ -90,7 +90,7 @@
try { // add some delay
Thread.sleep(1000);
} catch (final InterruptedException e) {
- Thread.interrupted();
+ Thread.currentThread().interrupt();
fail();
}
}
diff --git a/tools/cli/src/main/java/org/apache/batchee/cli/command/StartableCommand.java b/tools/cli/src/main/java/org/apache/batchee/cli/command/StartableCommand.java
index a3484ae..98adc00 100644
--- a/tools/cli/src/main/java/org/apache/batchee/cli/command/StartableCommand.java
+++ b/tools/cli/src/main/java/org/apache/batchee/cli/command/StartableCommand.java
@@ -105,7 +105,7 @@
}
adminThread.join();
} catch (final InterruptedException e) {
- Thread.interrupted();
+ Thread.currentThread().interrupt();
}
} // else let it live
}
diff --git a/tools/cli/src/test/java/org/apache/batchee/cli/MainTest.java b/tools/cli/src/test/java/org/apache/batchee/cli/MainTest.java
index 188a606..e89a89c 100644
--- a/tools/cli/src/test/java/org/apache/batchee/cli/MainTest.java
+++ b/tools/cli/src/test/java/org/apache/batchee/cli/MainTest.java
@@ -117,7 +117,7 @@
try {
sleep(100); // ensure it is started
} catch (final InterruptedException e) {
- Thread.interrupted();
+ Thread.currentThread().interrupt();
}
main(new String[]{"running"});
assertThat(stdout.getLog(), containsString("long-sample -> ["));
