diff --git a/velox/exec/tests/HashJoinTestExtra.cpp b/velox/exec/tests/HashJoinTestExtra.cpp index 65ea3dcf699..4e224f1632d 100644 --- a/velox/exec/tests/HashJoinTestExtra.cpp +++ b/velox/exec/tests/HashJoinTestExtra.cpp @@ -3838,26 +3838,19 @@ TEST_P(HashJoinTest, antiJoinAbandonBuildNoDupHashEarly) { TEST_P(HashJoinTest, semiJoinDeduplicateResetCapacity) { const int32_t vectorSize = 10; - const int32_t batches = 210; - auto probeVectors = makeBatches(batches, [&](int32_t /*unused*/) { - return makeRowVector({ - // Join Key is double -> VectorHasher::typeKindSupportsValueIds will - // return false -> HashMode is kHash - makeFlatVector( - vectorSize, [&](vector_size_t /*row*/) { return rand(); }), - makeFlatVector( - vectorSize, [&](vector_size_t /*row*/) { return rand(); }), - }); - }); + const int32_t numBatches = 210; + VectorFuzzer fuzzer({.vectorSize = vectorSize}, pool()); - auto buildVectors = makeBatches(batches, [&](int32_t batch) { - return makeRowVector({ - makeFlatVector( - vectorSize, [&](vector_size_t /*row*/) { return rand(); }), - makeFlatVector( - vectorSize, [&](vector_size_t /*row*/) { return rand(); }), - }); - }); + // Row type with double and int64_t columns + // Join Key is double -> VectorHasher::typeKindSupportsValueIds will + // return false -> HashMode is kHash + auto rowType = ROW({"c0", "c1"}, {DOUBLE(), BIGINT()}); + + auto probeVectors = makeBatches( + numBatches, [&](int32_t /*unused*/) { return fuzzer.fuzzRow(rowType); }); + + auto buildVectors = makeBatches( + numBatches, [&](int32_t /*unused*/) { return fuzzer.fuzzRow(rowType); }); createDuckDbTable("t", probeVectors); createDuckDbTable("u", buildVectors);