Skip to content

Commit de6a0e4

Browse files
committed
fix
1 parent 1ff7db2 commit de6a0e4

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

cpp/velox/jni/VeloxJniWrapper.cc

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1063,7 +1063,7 @@ JNIEXPORT jlong JNICALL Java_org_apache_gluten_vectorized_HashJoinBuilder_native
10631063

10641064
auto* cache = facebook::velox::exec::HashTableCache::instance();
10651065

1066-
if (!cache->hasTable(hashTableId)) {
1066+
if (!cache->exist(hashTableId)) {
10671067
cache->add(hashTableId, builder->hashTable(), builder->joinHasNullKeys(), defaultLeafVeloxMemoryPool());
10681068
}
10691069

@@ -1147,7 +1147,7 @@ JNIEXPORT jlong JNICALL Java_org_apache_gluten_vectorized_HashJoinBuilder_native
11471147
hashTableBuilders[0]->setHashTable(std::move(mainTable));
11481148

11491149
auto* cache = facebook::velox::exec::HashTableCache::instance();
1150-
if (!cache->hasTable(hashTableId)) {
1150+
if (!cache->exist(hashTableId)) {
11511151
cache->add(
11521152
hashTableId,
11531153
hashTableBuilders[0]->hashTable(),
@@ -1168,7 +1168,7 @@ JNIEXPORT jlong JNICALL Java_org_apache_gluten_vectorized_HashJoinBuilder_cloneH
11681168
auto cacheKeyStr = jStringToCString(env, cacheKey);
11691169
auto hashTableHandler = ObjectStore::retrieve<gluten::HashTableBuilder>(tableHandler);
11701170
auto* cache = facebook::velox::exec::HashTableCache::instance();
1171-
if (!cache->hasTable(cacheKeyStr)) {
1171+
if (!cache->exist(cacheKeyStr)) {
11721172
cache->add(
11731173
cacheKeyStr, hashTableHandler->hashTable(), hashTableHandler->joinHasNullKeys(), defaultLeafVeloxMemoryPool());
11741174
}

0 commit comments

Comments
 (0)