fix doc

Signed-off-by: Yashash H L <[email protected]>

Author: yhl25

numaflow/src/serving_store.rs

@@ -18,8 +18,8 @@ const DEFAULT_SOCK_ADDR: &str = "/var/run/numaflow/serving.sock";
 const DEFAULT_SERVER_INFO_FILE: &str = "/var/run/numaflow/serving-server-info";
 
 /// ServingStore trait for implementing user defined stores. This Store has to be
-/// a shared Store between the Source and the Sink vertices. [put] happens in Sink
-/// while the [get] gets called at the Source.
+/// a shared Store between the Source and the Sink vertices. [ServingStore::put] happens in Sink
+/// while the [ServingService::get] gets called at the serving layer.
 ///
 /// Types implementing this trait can be passed as user-defined store handle.
 #[tonic::async_trait]

numaflow/src/sink.rs

@@ -131,7 +131,7 @@ pub struct Response {
     pub id: String,
     /// response_type indicates the type of the response.
     pub response_type: ResponseType,
-    /// err string is used to describe the error if [`Response::success`]  was `false`.
+    /// err string is used to describe the error if [`ResponseType::Failure`]  is set.
     pub err: Option<String>,
     pub serve_response: Option<Vec<u8>>,
 }
@@ -259,7 +259,6 @@ where
                 grpc_resp_tx.clone(),
             )
             .await?;
-            println!("Time taken for batch: {:?}", start.elapsed().as_micros());
         }
         Ok(())
     }