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);
     }
 
     /**