Fix

Author: rui-mo

velox/common/memory/SharedArbitrator.cpp

@@ -424,10 +424,11 @@ uint64_t SharedArbitrator::reclaim(
     const uint64_t newCapacity = pool->capacity();
     VELOX_CHECK_GE(oldCapacity, newCapacity);
     reclaimedBytes = oldCapacity - newCapacity;
-  numReclaimedBytes_ += reclaimedBytes - freedBytes;
-  numShrunkBytes_ += freedBytes;
-  reclaimTimeUs_ += reclaimDurationUs;
-  return reclaimedBytes;
+    numReclaimedBytes_ += reclaimedBytes - freedBytes;
+    numShrunkBytes_ += freedBytes;
+    reclaimTimeUs_ += reclaimDurationUs;
+    return reclaimedBytes;
+  }
 }
 
 void SharedArbitrator::abort(

velox/functions/sparksql/DecimalVectorFunctions.cpp

@@ -235,8 +235,9 @@ class DecimalRoundFunction : public exec::VectorFunction {
       uint8_t rScale,
       int32_t scale) const {
     if (scale >= 0) {
+      bool isOverflow = false;
       auto rescaledValue = DecimalUtil::rescaleWithRoundUp<A, R>(
-          a, aPrecision, aScale, rPrecision, rScale);
+          a, aPrecision, aScale, rPrecision, rScale, isOverflow);
       VELOX_DCHECK(rescaledValue.has_value());
       r = rescaledValue.value();
     } else {

velox/functions/sparksql/aggregates/AverageAggregate.cpp

@@ -280,8 +280,9 @@ class DecimalAverageAggregate : public DecimalAggregate<TInputType> {
 
     DecimalUtil::divideWithRoundUp<int128_t, int128_t, int128_t>(
         avg, validSum.value(), countDecimal, false, sumRescale, 0);
+    bool isOverflow = false;
     return DecimalUtil::rescaleWithRoundUp<int128_t, TResultType>(
-        avg, avgPrecision, avgScale, resultPrecision, resultScale);
+        avg, avgPrecision, avgScale, resultPrecision, resultScale, isOverflow);
   }
 
  private:

velox/functions/sparksql/aggregates/DecimalSumAggregate.h

@@ -74,7 +74,7 @@ class DecimalSumAggregate : public exec::Aggregate {
 
     auto [resultPrecision, resultScale] =
         getDecimalPrecisionScale(*sumType_.get());
-    overflow = !DecimalUtil::valueInRangeWithPrecision(sum, resultPrecision);
+    overflow = !DecimalUtil::valueInPrecisionRange(sum, resultPrecision);
     return sum;
   }