.

Signed-off-by: Keran Yang <[email protected]>
numaproj · Nov 5, 2024 · a078db4 · a078db4
1 parent ff8b22b
commit a078db4
Show file tree

Hide file tree

Showing 5 changed files with 4 additions and 6 deletions.
diff --git 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
@@ -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
@@ -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
@@ -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
@@ -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");