diff --git a/examples/pom.xml b/examples/pom.xml
index b40c2dc..55a0020 100644
--- a/examples/pom.xml
+++ b/examples/pom.xml
@@ -17,7 +17,7 @@
         <dependency>
             <groupId>io.numaproj.numaflow</groupId>
             <artifactId>numaflow-java</artifactId>
-            <version>0.8.1</version>
+            <version>0.8.0</version>
         </dependency>
 
         <dependency>
diff --git a/examples/simple-pipeline.yaml b/examples/simple-pipeline.yaml
index 4aefe0e..753b38d 100644
--- a/examples/simple-pipeline.yaml
+++ b/examples/simple-pipeline.yaml
@@ -23,11 +23,10 @@ spec:
       sink:
         udsink:
           container:
-            image: quay.io/numaio/numaflow-java/simple-sink:keran-3
+            image: quay.io/numaio/numaflow-java/simple-sink:keran-11
             imagePullPolicy: Always
   edges:
     - from: in
       to: cat
     - from: cat
       to: java-sink
-
diff --git a/pom.xml b/pom.xml
index cef4002..6959b05 100644
--- a/pom.xml
+++ b/pom.xml
@@ -6,7 +6,7 @@
 
     <groupId>io.numaproj.numaflow</groupId>
     <artifactId>numaflow-java</artifactId>
-    <version>0.8.1</version>
+    <version>0.8.0</version>
     <packaging>jar</packaging>
 
     <name>numaflow-java</name>
diff --git a/src/main/java/io/numaproj/numaflow/sinker/Server.java b/src/main/java/io/numaproj/numaflow/sinker/Server.java
index b322695..99614c6 100644
--- a/src/main/java/io/numaproj/numaflow/sinker/Server.java
+++ b/src/main/java/io/numaproj/numaflow/sinker/Server.java
@@ -85,7 +85,6 @@ public void start() throws Exception {
             try {
                 Server.this.stop();
             } catch (InterruptedException e) {
-                // this one clears the interrupted status - I don't think it's not good.
                 if (Thread.interrupted()) {
                     System.err.println("Thread was interrupted when trying to stop the sink gRPC server.\n"
                             + "Thread interrupted status cleared");
diff --git a/src/main/java/io/numaproj/numaflow/sinker/Service.java b/src/main/java/io/numaproj/numaflow/sinker/Service.java
index b8cd595..a683fd6 100644
--- a/src/main/java/io/numaproj/numaflow/sinker/Service.java
+++ b/src/main/java/io/numaproj/numaflow/sinker/Service.java
@@ -218,7 +218,7 @@ public void shutDown() {
             }
             log.info("Sink executor was terminated.");
         } catch (InterruptedException e) {
-            // this one clears the interrupted status - I don't think it's not good.
+            // this one clears the interrupted status
             if (Thread.interrupted()) {
                 System.err.println("Thread was interrupted when trying to stop the sink service task executor.\n"
                         + "Thread interrupted status cleared");