wassname/ray
1
0
Fork 0
mirror of https://github.com/wassname/ray.git synced 2026-06-27 20:53:14 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix ray java worker metric registry indentation (#9780)

Browse Source
This commit is contained in:
bermaker
2020-07-30 13:20:24 +08:00
committed by GitHub
parent 6464bf55c6
commit ccd6b90a42
2 changed files with 8 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
java/runtime/src/main/java/io/ray/runtime/metric/MetricConfig.java
+2 -3
View File
@@ -11,9 +11,8 @@ public class MetricConfig {
private static final int DEFAULT_THREAD_POLL_SIZE = 1;
private static final long DEFAULT_SHUTDOWN_WAIT_TIME_MS = 3000L;
public static final MetricConfig DEFAULT_CONFIG =
new MetricConfig(DEFAULT_TIME_INTERVAL_MS, DEFAULT_THREAD_POLL_SIZE,
DEFAULT_SHUTDOWN_WAIT_TIME_MS);
public static final MetricConfig DEFAULT_CONFIG = new MetricConfig(DEFAULT_TIME_INTERVAL_MS,
DEFAULT_THREAD_POLL_SIZE, DEFAULT_SHUTDOWN_WAIT_TIME_MS);
private final long timeIntervalMs;
private final int threadPoolSize;
java/runtime/src/main/java/io/ray/runtime/metric/MetricRegistry.java
+6 -6
View File
@@ -33,9 +33,9 @@ public class MetricRegistry {
if (!isRunning) {
this.metricConfig = metricConfig;
scheduledExecutorService = new ScheduledThreadPoolExecutor(metricConfig.threadPoolSize(),
new ThreadFactoryBuilder().setNameFormat("metric-registry-%d").build());
new ThreadFactoryBuilder().setNameFormat("metric-registry-%d").build());
scheduledExecutorService.scheduleAtFixedRate(this::update, metricConfig.timeIntervalMs(),
metricConfig.timeIntervalMs(), TimeUnit.MILLISECONDS);
metricConfig.timeIntervalMs(), TimeUnit.MILLISECONDS);
isRunning = true;
LOG.info("Finished startup metric registry, metricConfig is {}.", metricConfig);
}
@@ -47,15 +47,15 @@ public class MetricRegistry {
if (isRunning && scheduledExecutorService != null) {
try {
scheduledExecutorService.shutdownNow();
if (!scheduledExecutorService
.awaitTermination(metricConfig.shutdownWaitTimeMs(), TimeUnit.MILLISECONDS)) {
if (!scheduledExecutorService.awaitTermination(metricConfig.shutdownWaitTimeMs(),
TimeUnit.MILLISECONDS)) {
LOG.warn("Metric registry did not shut down in {}ms time, so try to shut down again.",
metricConfig.shutdownWaitTimeMs());
metricConfig.shutdownWaitTimeMs());
scheduledExecutorService.shutdownNow();
}
} catch (InterruptedException e) {
LOG.warn("Interrupted when shutting down metric registry, so try to shut down again.",
e.getMessage(), e);
e.getMessage(), e);
scheduledExecutorService.shutdownNow();
}
if (scheduledExecutorService.isShutdown()) {