Skip to content

Commit

Permalink
chore: typos
Browse files Browse the repository at this point in the history
  • Loading branch information
discord9 committed Jun 4, 2024
1 parent aa43be0 commit 53a7b55
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
4 changes: 2 additions & 2 deletions src/flow/src/compute/render/map.rs
Original file line number Diff line number Diff line change
Expand Up @@ -125,9 +125,9 @@ fn mfp_subgraph(
false
}
});
let future_udpates = all_updates;
let future_updates = all_updates;

arrange.write().apply_updates(now, future_udpates)?;
arrange.write().apply_updates(now, future_updates)?;
Ok(())
};
err_collector.run(run_mfp);
Expand Down
2 changes: 1 addition & 1 deletion src/flow/src/repr.rs
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,7 @@ pub type KeyValDiffRow = ((Row, Row), Timestamp, Diff);

/// broadcast channel capacity, can be important to memory consumption, since this influence how many
/// updates can be buffered in memory in the entire dataflow
/// TODO(discord9): add config for this, so cpu&mem usage can be balanced and configed by this
/// TODO(discord9): add config for this, so cpu&mem usage can be balanced and configured by this
pub const BROADCAST_CAP: usize = 65535;

/// Convert a value that is or can be converted to Datetime to internal timestamp
Expand Down

0 comments on commit 53a7b55

Please sign in to comment.