Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

(WIP) debug graceful shutdown #151

Closed
wants to merge 6 commits into from
Closed

(WIP) debug graceful shutdown #151

wants to merge 6 commits into from

Conversation

KeranYang
Copy link
Member

No description provided.

Signed-off-by: Keran Yang <[email protected]>
.
Signed-off-by: Keran Yang <[email protected]>
Copy link

codecov bot commented Nov 4, 2024

Codecov Report

Attention: Patch coverage is 49.15254% with 30 lines in your changes missing coverage. Please review.

Please upload report for BASE (main@134414a). Learn more about missing BASE report.

Files with missing lines Patch % Lines
...main/java/io/numaproj/numaflow/sinker/Service.java 48.93% 23 Missing and 1 partial ⚠️
.../main/java/io/numaproj/numaflow/sinker/Server.java 50.00% 6 Missing ⚠️
Additional details and impacted files
@@           Coverage Diff           @@
##             main     #151   +/-   ##
=======================================
  Coverage        ?   60.06%           
  Complexity      ?      391           
=======================================
  Files           ?      126           
  Lines           ?     2817           
  Branches        ?      195           
=======================================
  Hits            ?     1692           
  Misses          ?      989           
  Partials        ?      136           

☔ View full report in Codecov by Sentry.
📢 Have feedback on the report? Share it here.

Signed-off-by: Keran Yang <[email protected]>
.
Signed-off-by: Keran Yang <[email protected]>
} catch (CompletionException ce) {
Throwable cause = ce.getCause(); // Get the original RuntimeException, if any.
log.error("Error occurred while processing messages: {}", cause.getMessage());
responseObserver.onError(cause); // Pass the error back to the client.
Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

don't directly send cause. not propagating the user exception.

.
Signed-off-by: Keran Yang <[email protected]>
@KeranYang KeranYang closed this Nov 6, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

1 participant