Skip to content
Permalink
Browse files
bad Thread.interrupted usage
  • Loading branch information
rmannibucau committed Apr 14, 2020
1 parent 28b1f70 commit d0669006dc537bcdd2e30d6ffc69274241fde0cc
Showing 3 changed files with 4 additions and 4 deletions.
@@ -81,7 +81,7 @@ public void cleanUpUntil() {

// 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 @@ public void cleanUpUntil() {
try { // add some delay
Thread.sleep(1000);
} catch (final InterruptedException e) {
Thread.interrupted();
Thread.currentThread().interrupt();
fail();
}
}
@@ -105,7 +105,7 @@ private void stopAdminThread(final AdminThread adminThread, final long id) {
}
adminThread.join();
} catch (final InterruptedException e) {
Thread.interrupted();
Thread.currentThread().interrupt();
}
} // else let it live
}
@@ -117,7 +117,7 @@ public void running() {
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 -> ["));

0 comments on commit d066900

Please sign in to comment.