natas_hw
/
dolphinscheduler0701
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Change interval to 500ms

This commit is contained in:
Wenjun Ruan 2024-06-27 12:33:55 +08:00
parent 665e611943
commit 98bf1d8019
4 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/controller/ResourcesController.java
View File

@ -93,8 +93,7 @@ public class ResourcesController extends BaseController {
private ResourcesService resourceService;
@Operation(summary = "queryResourceList", description = "QUERY_RESOURCE_LIST_NOTES")
@Parameters({
@Parameter(name = "type", description = "RESOURCE_TYPE", required = true, schema = @Schema(implementation = ResourceType.class))})
@Parameter(name = "type", description = "RESOURCE_TYPE", required = true, schema = @Schema(implementation = ResourceType.class))
@GetMapping(value = "/list")
@ResponseStatus(HttpStatus.OK)
@ApiException(QUERY_RESOURCES_LIST_ERROR)

7
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/model/BaseHeartBeatTask.java
View File

@ -73,7 +73,7 @@ public abstract class BaseHeartBeatTask<T extends HeartBeat> extends BaseDaemonT
try {
Thread.sleep(DEFAULT_HEARTBEAT_SCAN_INTERVAL);
} catch (InterruptedException e) {
ignoreInterruptException(e);
handleInterruptException(e);
}
}
}
@ -84,8 +84,9 @@ public abstract class BaseHeartBeatTask<T extends HeartBeat> extends BaseDaemonT
log.warn("{} finished...", threadName);
}
private void ignoreInterruptException(InterruptedException ex) {
log.warn("{} has been interrupted, but this will be ignore", threadName, ex);
private void handleInterruptException(InterruptedException ex) {
log.warn("{} has been interrupted", threadName, ex);
Thread.currentThread().interrupt();
}
public abstract T getHeartBeat();

2
dolphinscheduler-e2e/dolphinscheduler-e2e-core/src/main/java/org/apache/dolphinscheduler/e2e/core/DolphinSchedulerExtension.java
View File

@ -80,7 +80,7 @@ final class DolphinSchedulerExtension implements BeforeAllCallback, AfterAllCall
@SuppressWarnings("UnstableApiUsage")
public void beforeAll(ExtensionContext context) throws IOException {
Awaitility.setDefaultTimeout(Duration.ofSeconds(60));
Awaitility.setDefaultPollInterval(Duration.ofMillis(100));
Awaitility.setDefaultPollInterval(Duration.ofMillis(500));
setRecordPath();

2
dolphinscheduler-e2e/dolphinscheduler-e2e-core/src/main/java/org/apache/dolphinscheduler/e2e/core/WebDriverWaitFactory.java
View File

@ -23,7 +23,7 @@ import org.openqa.selenium.support.ui.WebDriverWait;
public class WebDriverWaitFactory {
private static final Duration DEFAULT_INTERVAL = Duration.ofMillis(100);
private static final Duration DEFAULT_INTERVAL = Duration.ofMillis(500);
private static final Duration DEFAULT_TIMEOUT = Duration.ofSeconds(60);