From f2172a091147629eaa94851b6c98f1c5c2b24e13 Mon Sep 17 00:00:00 2001 From: Keran Yang Date: Tue, 5 Nov 2024 12:55:23 -0500 Subject: [PATCH] . Signed-off-by: Keran Yang --- .../io/numaproj/numaflow/examples/sink/simple/SimpleSink.java | 4 ++++ src/main/java/io/numaproj/numaflow/sinker/Server.java | 2 +- 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/examples/src/main/java/io/numaproj/numaflow/examples/sink/simple/SimpleSink.java b/examples/src/main/java/io/numaproj/numaflow/examples/sink/simple/SimpleSink.java index a286ba4..5e3c1dd 100644 --- a/examples/src/main/java/io/numaproj/numaflow/examples/sink/simple/SimpleSink.java +++ b/examples/src/main/java/io/numaproj/numaflow/examples/sink/simple/SimpleSink.java @@ -25,6 +25,10 @@ public static void main(String[] args) throws Exception { // wait for the server to shut down server.awaitTermination(); + // take a thread dump using jstack + + // user wants to do cleanup after awaitTermiantion + log.info("Server stopped."); } diff --git a/src/main/java/io/numaproj/numaflow/sinker/Server.java b/src/main/java/io/numaproj/numaflow/sinker/Server.java index 99614c6..59058c5 100644 --- a/src/main/java/io/numaproj/numaflow/sinker/Server.java +++ b/src/main/java/io/numaproj/numaflow/sinker/Server.java @@ -108,7 +108,7 @@ public void awaitTermination() throws InterruptedException { log.info("Sink server is waiting for termination"); server.awaitTermination(); log.info("Sink server has terminated"); - System.exit(0); + // System.exit(0); } /**