This is an automated email from the ASF dual-hosted git repository.
marong pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-gluten.git
The following commit(s) were added to refs/heads/main by this push:
new 182a02999 [GLUTEN-5724][VL] Remove redundant counter for calculating
VeloxShuffleWriter spill time (#5725)
182a02999 is described below
commit 182a0299993b38e04ee053158f71b2500c59eb09
Author: Rong Ma <[email protected]>
AuthorDate: Tue May 14 09:43:10 2024 +0800
[GLUTEN-5724][VL] Remove redundant counter for calculating
VeloxShuffleWriter spill time (#5725)
---
cpp/core/shuffle/LocalPartitionWriter.cc | 3 ---
1 file changed, 3 deletions(-)
diff --git a/cpp/core/shuffle/LocalPartitionWriter.cc
b/cpp/core/shuffle/LocalPartitionWriter.cc
index b2c4e85b6..0582ce0e5 100644
--- a/cpp/core/shuffle/LocalPartitionWriter.cc
+++ b/cpp/core/shuffle/LocalPartitionWriter.cc
@@ -44,7 +44,6 @@ class LocalPartitionWriter::LocalSpiller {
codec_(codec) {}
arrow::Status spill(uint32_t partitionId, std::unique_ptr<BlockPayload>
payload) {
- ScopedTimer timer(&spillTime_);
// Check spill Type.
if (payload->type() != Payload::kUncompressed) {
return arrow::Status::Invalid(
@@ -317,8 +316,6 @@ class LocalPartitionWriter::PayloadCache {
arrow::Result<std::shared_ptr<Spill>>
spill(const std::string& spillFile, arrow::MemoryPool* pool,
arrow::util::Codec* codec) {
- ScopedTimer timer(&spillTime_);
-
std::shared_ptr<Spill> diskSpill = nullptr;
ARROW_ASSIGN_OR_RAISE(auto os,
arrow::io::FileOutputStream::Open(spillFile, true));
ARROW_ASSIGN_OR_RAISE(auto start, os->Tell());
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
