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

coord: check while dropping error'd sink connector #7563

Merged
merged 1 commit into from
Jul 28, 2021

Conversation

maddyblue
Copy link
Contributor

Fixes #7548

@maddyblue maddyblue requested a review from benesch July 27, 2021 21:07
self.catalog_transact(vec![catalog::Op::DropItem(id)])
.await
.expect("deleting placeholder sink cannot fail");
// Drop the placeholder sink if still present.
Copy link
Member

Choose a reason for hiding this comment

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

I think it'd be nice to make this look a bit like the else branch above and say something like "Another session may have dropped the placeholder sink while we were attempting to create the connector, in which case we don't need to do anything."

@maddyblue maddyblue enabled auto-merge July 28, 2021 20:04
@maddyblue maddyblue merged commit e787ab5 into MaterializeInc:main Jul 28, 2021
@maddyblue maddyblue deleted the sink-drop branch July 28, 2021 21:28
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.

panic: no entry found for key as message_sink_connector_ready attempts to fetch a sink that was just deleted
2 participants