Skip to content

Commit

Permalink
.
Browse files Browse the repository at this point in the history
Signed-off-by: Keran Yang <[email protected]>
KeranYang committed Nov 5, 2024
1 parent a078db4 commit f2172a0
Showing 2 changed files with 5 additions and 1 deletion.
Original file line number Diff line number Diff line change
@@ -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.");
}

2 changes: 1 addition & 1 deletion src/main/java/io/numaproj/numaflow/sinker/Server.java
Original file line number Diff line number Diff line change
@@ -108,7 +108,7 @@ public void awaitTermination() throws InterruptedException {
log.info("Sink server is waiting for termination");

Check warning on line 108 in src/main/java/io/numaproj/numaflow/sinker/Server.java

Codecov / codecov/patch

src/main/java/io/numaproj/numaflow/sinker/Server.java#L108

Added line #L108 was not covered by tests
server.awaitTermination();
log.info("Sink server has terminated");

Check warning on line 110 in src/main/java/io/numaproj/numaflow/sinker/Server.java

Codecov / codecov/patch

src/main/java/io/numaproj/numaflow/sinker/Server.java#L110

Added line #L110 was not covered by tests
System.exit(0);
// System.exit(0);
}

/**

0 comments on commit f2172a0

Please sign in to comment.