You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@arrow.apache.org by dh...@apache.org on 2023/06/28 19:15:13 UTC

[arrow-datafusion] 01/01: Add some more capacity to join hashmap

This is an automated email from the ASF dual-hosted git repository.

dheres pushed a commit to branch extra_capacity
in repository https://gitbox.apache.org/repos/asf/arrow-datafusion.git

commit 2e6b0d303319c401d7ef811c2fa6202427a9ad40
Author: Daniƫl Heres <da...@coralogix.com>
AuthorDate: Wed Jun 28 21:15:01 2023 +0200

    Add some more capacity to join hashmap
---
 datafusion/core/src/physical_plan/joins/hash_join_utils.rs | 2 +-
 testing                                                    | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/datafusion/core/src/physical_plan/joins/hash_join_utils.rs b/datafusion/core/src/physical_plan/joins/hash_join_utils.rs
index 1b9cbd543d..ad7804e27f 100644
--- a/datafusion/core/src/physical_plan/joins/hash_join_utils.rs
+++ b/datafusion/core/src/physical_plan/joins/hash_join_utils.rs
@@ -103,7 +103,7 @@ pub struct SymmetricJoinHashMap(pub RawTable<(u64, SmallVec<[u64; 1]>)>);
 impl JoinHashMap {
     pub(crate) fn with_capacity(capacity: usize) -> Self {
         JoinHashMap {
-            map: RawTable::with_capacity(capacity),
+            map: RawTable::with_capacity(capacity * 2),
             next: vec![0; capacity],
         }
     }
diff --git a/testing b/testing
index e81d0c6de3..5bab2f264a 160000
--- a/testing
+++ b/testing
@@ -1 +1 @@
-Subproject commit e81d0c6de35948b3be7984af8e00413b314cde6e
+Subproject commit 5bab2f264a23f5af68f69ea93d24ef1e8e77fc88