From b6d6df29224d81ad2e92d815b700fb062e3898b3 Mon Sep 17 00:00:00 2001 From: SAY-5 Date: Wed, 22 Apr 2026 03:01:48 -0700 Subject: [PATCH] chore: typo sweep (occured, recieved, nonexistant) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Ten single-character typo fixes across carnot, stirling, shared, table_store and vizier subtrees — comments and one error string. No functional change. --- src/carnot/exec/grpc_router.h | 2 +- src/carnot/funcs/builtins/sql_parsing/normalization.h | 2 +- src/carnot/funcs/metadata/metadata_ops_test.cc | 2 +- src/carnot/planner/distributed/grpc_source_conversion.cc | 2 +- src/carnot/planner/objects/qlobject.h | 2 +- src/carnot/planner/probes/probes.h | 2 +- src/shared/metadata/metadata_state.h | 2 +- .../source_connectors/socket_tracer/data_stream_test.cc | 2 +- src/table_store/table/table_store.h | 2 +- src/vizier/services/agent/shared/manager/chan_cache.h | 2 +- 10 files changed, 10 insertions(+), 10 deletions(-) diff --git a/src/carnot/exec/grpc_router.h b/src/carnot/exec/grpc_router.h index ba40c66dd97..833dce83226 100644 --- a/src/carnot/exec/grpc_router.h +++ b/src/carnot/exec/grpc_router.h @@ -81,7 +81,7 @@ class GRPCRouter final : public carnotpb::ResultSinkService::Service { Status DeleteGRPCSourceNode(sole::uuid query_id, int64_t source_id); /** - * @brief Get any errors that may have occured in the incoming worker nodes. + * @brief Get any errors that may have occurred in the incoming worker nodes. * * @param query_id * @return StatusOr> diff --git a/src/carnot/funcs/builtins/sql_parsing/normalization.h b/src/carnot/funcs/builtins/sql_parsing/normalization.h index ef7e91d8653..1a31dc22fc3 100644 --- a/src/carnot/funcs/builtins/sql_parsing/normalization.h +++ b/src/carnot/funcs/builtins/sql_parsing/normalization.h @@ -141,7 +141,7 @@ std::ostream& operator<<(std::ostream& os, const NormalizeResult& result); struct NormalizationState { // Number of characters to shift character indices into the query by, to account for replacements - // that have already occured. + // that have already occurred. int n_shift_query = 0; std::vector line_start_offsets; std::string next_placeholder; diff --git a/src/carnot/funcs/metadata/metadata_ops_test.cc b/src/carnot/funcs/metadata/metadata_ops_test.cc index b9d225326bb..03cdc08c592 100644 --- a/src/carnot/funcs/metadata/metadata_ops_test.cc +++ b/src/carnot/funcs/metadata/metadata_ops_test.cc @@ -542,7 +542,7 @@ TEST_F(MetadataOpsTest, pod_name_to_stop_time) { auto function_ctx = std::make_unique(metadata_state_, nullptr); // pl/terminating_pod is the Pod name for a terminating pod. EXPECT_EQ(udf.Exec(function_ctx.get(), "pl/terminating_pod").val, 15); - // pl/blah is a nonexistant Pod, should return 0. + // pl/blah is a nonexistent Pod, should return 0. EXPECT_EQ(udf.Exec(function_ctx.get(), "pl/blah").val, 0); } diff --git a/src/carnot/planner/distributed/grpc_source_conversion.cc b/src/carnot/planner/distributed/grpc_source_conversion.cc index d0fcfe15031..a56c64a8f69 100644 --- a/src/carnot/planner/distributed/grpc_source_conversion.cc +++ b/src/carnot/planner/distributed/grpc_source_conversion.cc @@ -114,7 +114,7 @@ StatusOr MergeSameNodeGRPCBridgeRule::Apply(IRNode* ir_node) { int64_t dest_id = grpc_sink->agent_id_to_destination_id().at(current_agent_id_); auto node = grpc_sink->graph()->Get(dest_id); if (!Match(node, GRPCSource())) { - return node->CreateIRNodeError("Expected node to be a 'GRPCSource', but recieved a '$0'", + return node->CreateIRNodeError("Expected node to be a 'GRPCSource', but received a '$0'", node->DebugString()); } auto grpc_sink_parent = grpc_sink->parents()[0]; diff --git a/src/carnot/planner/objects/qlobject.h b/src/carnot/planner/objects/qlobject.h index 4231fb78b0e..7412b95b70d 100644 --- a/src/carnot/planner/objects/qlobject.h +++ b/src/carnot/planner/objects/qlobject.h @@ -189,7 +189,7 @@ class QLObject { /** * @brief Creates an error for this objects. Packages checks to make sure you have an ir node for - * line,col error resporting. Defaults to standard error in case an ir node is nonexistant.. + * line,col error resporting. Defaults to standard error in case an ir node is nonexistent. * * @return Status */ diff --git a/src/carnot/planner/probes/probes.h b/src/carnot/planner/probes/probes.h index 3578cdb33d6..b7c8cea4417 100644 --- a/src/carnot/planner/probes/probes.h +++ b/src/carnot/planner/probes/probes.h @@ -78,7 +78,7 @@ class TracepointIR { * @brief Serializes this probe definition as a protobuf. * * @param pb - * @return Any error that occured during serialization. + * @return Any error that occurred during serialization. */ Status ToProto(carnot::planner::dynamic_tracing::ir::logical::TracepointSpec* pb, const std::string& name); diff --git a/src/shared/metadata/metadata_state.h b/src/shared/metadata/metadata_state.h index e2fdc9e6c86..b467bbc38ab 100644 --- a/src/shared/metadata/metadata_state.h +++ b/src/shared/metadata/metadata_state.h @@ -157,7 +157,7 @@ class K8sMetadataState : NotCopyable { /** * PodIDByIPAtTime returns the PodID for the pod with the given IP at the given timestamp. * @param pod_ip string of the pod IP. - * @param timestamp_ns time at which this request occured. + * @param timestamp_ns time at which this request occurred. * @return the pod_id or empty string if the pod does not exist. */ UID PodIDByIPAtTime(std::string_view pod_ip, int64_t timestamp_ns) const; diff --git a/src/stirling/source_connectors/socket_tracer/data_stream_test.cc b/src/stirling/source_connectors/socket_tracer/data_stream_test.cc index 693496df826..d7b9d1a160f 100644 --- a/src/stirling/source_connectors/socket_tracer/data_stream_test.cc +++ b/src/stirling/source_connectors/socket_tracer/data_stream_test.cc @@ -495,7 +495,7 @@ TEST_F(DataStreamTest, SpikeCapacityWithLargeDataChunkAndSSLEnabled) { } TEST_F(DataStreamTest, ResyncCausesDuplicateEventBug) { - // Test to catch regression on a bug. The bug occured when a resync occurs in ParseFrames, leading + // Test to catch regression on a bug. The bug occurred when a resync occurs in ParseFrames, leading // to an invalid state where the data stream buffer still had data that had already been // processed. std::unique_ptr req0a = diff --git a/src/table_store/table/table_store.h b/src/table_store/table/table_store.h index 45eb1944426..17969ed4f13 100644 --- a/src/table_store/table/table_store.h +++ b/src/table_store/table/table_store.h @@ -180,7 +180,7 @@ class TableStore { * * @param table_id: table_id within which to create a tablet. * @param tablet_id: the tablet to create for the tablet. - * @return StatusOr: the table object or an error if the table is nonexistant. + * @return StatusOr: the table object or an error if the table is nonexistent. */ StatusOr CreateNewTablet(uint64_t table_id, const types::TabletID& tablet_id); diff --git a/src/vizier/services/agent/shared/manager/chan_cache.h b/src/vizier/services/agent/shared/manager/chan_cache.h index 6520a1c03a9..ff5f6cfe420 100644 --- a/src/vizier/services/agent/shared/manager/chan_cache.h +++ b/src/vizier/services/agent/shared/manager/chan_cache.h @@ -72,7 +72,7 @@ class ChanCache { * The period where a connection goes from READY to IDLE can be adjusted with the channel * argument: GRPC_ARG_CLIENT_IDLE_TIMEOUT_MS. See the test for an example. * - * @return Status: whether an error occured while cleaning up Idle/Dead Channels. + * @return Status: whether an error occurred while cleaning up Idle/Dead Channels. */ Status CleanupChans();