Skip to content

Commit

Permalink
update comment
Browse files Browse the repository at this point in the history
  • Loading branch information
xzhseh committed Apr 18, 2024
1 parent 1fc8996 commit bd71443
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/connector/src/sink/snowflake.rs
Original file line number Diff line number Diff line change
Expand Up @@ -241,7 +241,7 @@ impl SnowflakeSinkWriter {
/// note: should *only* be called iff after a new epoch begins,
/// and `streaming_upload` being called the first time.
/// i.e., lazily initialization of the internal `streaming_uploader`.
/// plus, this function is *pure*, the `&mut self` is to make rustc (and tokio) happy.
/// plus, this function is *pure*, the `&mut self` here is to make rustc (and tokio) happy.
async fn new_streaming_uploader(&mut self) -> Result<(Box<dyn StreamingUploader>, String)> {
let file_suffix = self.file_suffix();
let path = generate_s3_file_name(self.s3_client.s3_path(), &file_suffix);
Expand Down

0 comments on commit bd71443

Please sign in to comment.