This is an automated email from the ASF dual-hosted git repository.
suneet pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
The following commit(s) were added to refs/heads/master by this push:
new c8537dbeaf Add lifecycle hooks to KubernetesTaskRunner (#14790)
c8537dbeaf is described below
commit c8537dbeafe9238ccb83077be2280b23ae7bfea5
Author: George Shiqi Wu <[email protected]>
AuthorDate: Thu Aug 10 00:16:44 2023 -0400
Add lifecycle hooks to KubernetesTaskRunner (#14790)
---
.../main/java/org/apache/druid/k8s/overlord/KubernetesTaskRunner.java | 4 ++++
1 file changed, 4 insertions(+)
diff --git
a/extensions-contrib/kubernetes-overlord-extensions/src/main/java/org/apache/druid/k8s/overlord/KubernetesTaskRunner.java
b/extensions-contrib/kubernetes-overlord-extensions/src/main/java/org/apache/druid/k8s/overlord/KubernetesTaskRunner.java
index 89d33c7404..99095264c3 100644
---
a/extensions-contrib/kubernetes-overlord-extensions/src/main/java/org/apache/druid/k8s/overlord/KubernetesTaskRunner.java
+++
b/extensions-contrib/kubernetes-overlord-extensions/src/main/java/org/apache/druid/k8s/overlord/KubernetesTaskRunner.java
@@ -42,6 +42,8 @@ import org.apache.druid.java.util.common.DateTimes;
import org.apache.druid.java.util.common.ISE;
import org.apache.druid.java.util.common.Pair;
import org.apache.druid.java.util.common.concurrent.Execs;
+import org.apache.druid.java.util.common.lifecycle.LifecycleStart;
+import org.apache.druid.java.util.common.lifecycle.LifecycleStop;
import org.apache.druid.java.util.emitter.EmittingLogger;
import org.apache.druid.java.util.emitter.service.ServiceEmitter;
import org.apache.druid.java.util.emitter.service.ServiceMetricEvent;
@@ -325,6 +327,7 @@ public class KubernetesTaskRunner implements
TaskLogStreamer, TaskRunner
}
@Override
+ @LifecycleStart
public void start()
{
cleanupExecutor.scheduleAtFixedRate(
@@ -342,6 +345,7 @@ public class KubernetesTaskRunner implements
TaskLogStreamer, TaskRunner
@Override
+ @LifecycleStop
public void stop()
{
log.debug("Stopping KubernetesTaskRunner");
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
