Skip to content

Commit

Permalink
update comment
Browse files Browse the repository at this point in the history
  • Loading branch information
xzhseh committed Mar 12, 2024
1 parent 5b26ccd commit 8bc0bf4
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions src/connector/src/sink/snowflake.rs
Original file line number Diff line number Diff line change
Expand Up @@ -213,13 +213,13 @@ impl SnowflakeSinkWriter {
}
}

/// Note that we shall NOT reset the `sink_file_suffix`
/// since we need to incrementally keep the sink
/// file *unique*, otherwise snowflake will not
/// sink it from external stage (i.e., s3)
fn reset(&mut self) {
self.payload.clear();
self.row_counter = 0;
// Note that we shall NOT reset the `sink_file_suffix`
// since we need to incrementally keep the sink
// file *unique*, otherwise snowflake will not
// sink it from external stage (i.e., s3)
}

fn at_sink_threshold(&self) -> bool {
Expand Down

0 comments on commit 8bc0bf4

Please sign in to comment.