This is an automated email from the ASF dual-hosted git repository.
HappenLee pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 422a703f6a5 [fix](fe) Preserve analytic window row offsets (#65679)
422a703f6a5 is described below
commit 422a703f6a52ae3eec5e035c54c9b322dc8a4b20
Author: TengJianPing <[email protected]>
AuthorDate: Tue Jul 28 15:33:46 2026 +0800
[fix](fe) Preserve analytic window row offsets (#65679)
Problem Summary:
1. Nereids converted ROWS window offsets through double. Long.MAX_VALUE
was rounded to 2^63 and serialized as Long.MIN_VALUE, causing BE frame
arithmetic to address an invalid LAG default row and crash.
This PR preserve offsets exactly, reject values larger than INT64_MAX。
2. Nereids checked LEAD and LAG offsets only after function signature
coercion. A decimal offset was therefore converted to BIGINT before
validation and incorrectly accepted. Validate the original offset type
before coercion so non-integer offsets fail during FE analysis, and add
regression and unit coverage for both functions.
### Release note
ROWS window offsets greater than INT64_MAX are rejected. LEAD and LAG
reject non-integer offset arguments before type coercion.
---
.../org/apache/doris/analysis/AnalyticWindow.java | 6 +-
.../rules/analysis/WindowFunctionChecker.java | 38 ++-
.../trees/expressions/functions/window/Lag.java | 5 +
.../trees/expressions/functions/window/Lead.java | 5 +
.../functions/window/WindowFunction.java | 22 ++
.../doris/nereids/trees/plans/algebra/Window.java | 2 +-
.../apache/doris/analysis/AnalyticWindowTest.java | 58 ++++
.../CheckAndStandardizeWindowFunctionTest.java | 2 +-
.../functions/window/LeadLagOffsetTest.java | 88 +++++++
.../test_lead_lag_large_offset.groovy | 292 +++++++++++++++++++++
10 files changed, 502 insertions(+), 16 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/AnalyticWindow.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/AnalyticWindow.java
index 5980a501a1d..5325fb07d0a 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/AnalyticWindow.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/AnalyticWindow.java
@@ -35,6 +35,8 @@ import java.util.Objects;
* Both left and right boundaries are always non-null after analyze().
*/
public class AnalyticWindow {
+ private static final BigDecimal MAX_ROWS_OFFSET_VALUE =
BigDecimal.valueOf(Long.MAX_VALUE);
+
public enum Type {
ROWS("ROWS"),
RANGE("RANGE");
@@ -139,7 +141,9 @@ public class AnalyticWindow {
TAnalyticWindowBoundary result = new
TAnalyticWindowBoundary(type.toThrift());
if (type.isOffset() && windowType == Type.ROWS) {
- result.setRowsOffsetValue(offsetValue.longValue());
+
Preconditions.checkState(offsetValue.compareTo(MAX_ROWS_OFFSET_VALUE) <= 0,
+ "ROWS window offset must not exceed " +
Long.MAX_VALUE);
+ result.setRowsOffsetValue(offsetValue.longValueExact());
}
// TODO: range windows need range_offset_predicate
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/WindowFunctionChecker.java
b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/WindowFunctionChecker.java
index 20d59e9bc4d..31b2ae5b166 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/WindowFunctionChecker.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/WindowFunctionChecker.java
@@ -48,6 +48,7 @@ import
org.apache.doris.nereids.trees.expressions.visitor.DefaultExpressionVisit
import com.google.common.base.Preconditions;
import com.google.common.collect.ImmutableList;
+import java.math.BigDecimal;
import java.util.List;
import java.util.Optional;
import java.util.stream.Collectors;
@@ -66,6 +67,7 @@ import java.util.stream.Collectors;
* window frame (RANGE between UNBOUNDED PRECEDING and CURRENT ROW)
*/
public class WindowFunctionChecker extends
DefaultExpressionVisitor<Expression, Void> {
+ private static final BigDecimal MAX_ROWS_OFFSET_VALUE =
BigDecimal.valueOf(Long.MAX_VALUE);
private WindowExpression windowExpression;
@@ -183,14 +185,14 @@ public class WindowFunctionChecker extends
DefaultExpressionVisitor<Expression,
// case 5
// check correctness of left boundary and right boundary
if (left.hasOffset() && right.hasOffset()) {
- double leftOffsetValue = ((Literal)
left.getBoundOffset().get()).getDouble();
- double rightOffsetValue = ((Literal)
right.getBoundOffset().get()).getDouble();
+ BigDecimal leftOffsetValue = getBoundOffsetValue(left);
+ BigDecimal rightOffsetValue = getBoundOffsetValue(right);
if (left.asPreceding() && right.asPreceding()) {
- Preconditions.checkArgument(leftOffsetValue >=
rightOffsetValue, "WindowFrame with "
+
Preconditions.checkArgument(leftOffsetValue.compareTo(rightOffsetValue) >= 0,
"WindowFrame with "
+ "PRECEDING boundary requires that leftBoundOffset >=
rightBoundOffset");
} else if (left.asFollowing() && right.asFollowing()) {
- Preconditions.checkArgument(leftOffsetValue <=
rightOffsetValue, "WindowFrame with "
- + "FOLLOWING boundary requires that leftBoundOffset >=
rightBoundOffset");
+
Preconditions.checkArgument(leftOffsetValue.compareTo(rightOffsetValue) <= 0,
"WindowFrame with "
+ + "FOLLOWING boundary requires that leftBoundOffset <=
rightBoundOffset");
}
}
@@ -200,9 +202,9 @@ public class WindowFunctionChecker extends
DefaultExpressionVisitor<Expression,
/**
* check boundOffset of FrameBoundary if it exists:
* 1 boundOffset should be Literal, but this restriction can be removed
after completing FoldConstant
- * 2 boundOffset should be positive
- * 2 boundOffset should be a positive INTEGER if FrameUnitsType == ROWS
- * 3 boundOffset should be a positive INTEGER or DECIMAL if FrameUnitsType
== RANGE
+ * 2 boundOffset should be an INTEGER if FrameUnitsType == ROWS
+ * 3 boundOffset should be an INTEGER or DECIMAL if FrameUnitsType == RANGE
+ * 4 boundOffset should be positive
*/
private void checkFrameBoundOffset(FrameBoundary frameBoundary) {
Expression offset = frameBoundary.getBoundOffset().get();
@@ -211,21 +213,31 @@ public class WindowFunctionChecker extends
DefaultExpressionVisitor<Expression,
Preconditions.checkArgument(offset.isLiteral(), "BoundOffset of
WindowFrame must be Literal");
// case 2
- boolean isPositive = ((Literal) offset).getDouble() > 0;
- Preconditions.checkArgument(isPositive, "BoundOffset of WindowFrame
must be positive");
-
- // case 3
FrameUnitsType frameUnits =
windowExpression.getWindowFrame().get().getFrameUnits();
if (frameUnits == FrameUnitsType.ROWS) {
Preconditions.checkArgument(offset.getDataType().isIntegralType(),
"BoundOffset of ROWS WindowFrame must be an Integer");
}
- // case 4
+ // case 3
if (frameUnits == FrameUnitsType.RANGE) {
Preconditions.checkArgument(offset.getDataType().isNumericType(),
"BoundOffset of RANGE WindowFrame must be an Integer or
Decimal");
}
+
+ // case 4
+ BigDecimal offsetValue = getBoundOffsetValue(frameBoundary);
+ boolean isPositive = offsetValue.compareTo(BigDecimal.ZERO) > 0;
+ Preconditions.checkArgument(isPositive, "BoundOffset of WindowFrame
must be positive");
+
+ if (frameUnits == FrameUnitsType.ROWS) {
+
Preconditions.checkArgument(offsetValue.compareTo(MAX_ROWS_OFFSET_VALUE) <= 0,
+ "BoundOffset of ROWS WindowFrame must not exceed " +
Long.MAX_VALUE);
+ }
+ }
+
+ private BigDecimal getBoundOffsetValue(FrameBoundary frameBoundary) {
+ return new BigDecimal(((Literal)
frameBoundary.getBoundOffset().get()).getStringValue());
}
/*
********************************************************************************************
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/window/Lag.java
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/window/Lag.java
index 1cf808e32f7..cee27a2fa21 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/window/Lag.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/window/Lag.java
@@ -92,6 +92,11 @@ public class Lag extends WindowFunction implements
TernaryExpression, Explicitly
return new Lag(getFunctionParams(children));
}
+ @Override
+ public void checkLegalityBeforeTypeCoercion() {
+ checkOffsetBeforeTypeCoercion(getArgument(1), "LAG");
+ }
+
@Override
public void checkLegalityAfterRewrite() {
if (children().size() == 1) {
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/window/Lead.java
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/window/Lead.java
index a3a21ce20ca..b222215507d 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/window/Lead.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/window/Lead.java
@@ -93,6 +93,11 @@ public class Lead extends WindowFunction implements
TernaryExpression, Explicitl
return visitor.visitLead(this, context);
}
+ @Override
+ public void checkLegalityBeforeTypeCoercion() {
+ checkOffsetBeforeTypeCoercion(getArgument(1), "LEAD");
+ }
+
@Override
public void checkLegalityAfterRewrite() {
if (children().size() == 1) {
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/window/WindowFunction.java
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/window/WindowFunction.java
index 3fe5d4ec334..7f5b8052a1f 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/window/WindowFunction.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/window/WindowFunction.java
@@ -20,8 +20,10 @@ package
org.apache.doris.nereids.trees.expressions.functions.window;
import org.apache.doris.nereids.exceptions.AnalysisException;
import org.apache.doris.nereids.trees.expressions.Expression;
import org.apache.doris.nereids.trees.expressions.functions.BoundFunction;
+import org.apache.doris.nereids.trees.expressions.literal.Literal;
import org.apache.doris.nereids.types.DataType;
+import java.math.BigDecimal;
import java.util.List;
import java.util.Objects;
@@ -30,6 +32,8 @@ import java.util.Objects;
*/
public abstract class WindowFunction extends BoundFunction implements
SupportWindowAnalytic {
+ private static final BigDecimal MAX_BIGINT_OFFSET =
BigDecimal.valueOf(Long.MAX_VALUE);
+
public WindowFunction(String name, Expression... arguments) {
super(name, arguments);
}
@@ -79,4 +83,22 @@ public abstract class WindowFunction extends BoundFunction
implements SupportWin
"The parameter 2 of LAG/LEAD must be a constant value: " +
this.toSql());
}
}
+
+ protected void checkOffsetBeforeTypeCoercion(Expression offset, String
functionName) {
+ if (!offset.getDataType().isIntegralType()) {
+ throw new AnalysisException("The offset parameter of " +
functionName
+ + " must be a constant positive integer: " + this.toSql());
+ }
+ if (offset instanceof Literal) {
+ BigDecimal offsetValue = new BigDecimal(((Literal)
offset).getStringValue());
+ if (offsetValue.compareTo(BigDecimal.ZERO) < 0) {
+ throw new AnalysisException("The offset parameter of " +
functionName
+ + " must be a constant positive integer: " +
this.toSql());
+ }
+ if (offsetValue.compareTo(MAX_BIGINT_OFFSET) > 0) {
+ throw new AnalysisException("The offset parameter of " +
functionName
+ + " must not exceed " + Long.MAX_VALUE + ": " +
this.toSql());
+ }
+ }
+ }
}
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/algebra/Window.java
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/algebra/Window.java
index 1dacda593dc..e5bb780a908 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/algebra/Window.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/algebra/Window.java
@@ -76,7 +76,7 @@ public interface Window {
Expr e = null;
if (boundary.hasOffset()) {
Expression boundOffset = boundary.getBoundOffset().get();
- offsetValue = new BigDecimal(((Literal) boundOffset).getDouble());
+ offsetValue = new BigDecimal(((Literal)
boundOffset).getStringValue());
e = ExpressionTranslator.translate(boundOffset, context);
}
diff --git
a/fe/fe-core/src/test/java/org/apache/doris/analysis/AnalyticWindowTest.java
b/fe/fe-core/src/test/java/org/apache/doris/analysis/AnalyticWindowTest.java
new file mode 100644
index 00000000000..2fc61903a9b
--- /dev/null
+++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/AnalyticWindowTest.java
@@ -0,0 +1,58 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements. See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership. The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied. See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+package org.apache.doris.analysis;
+
+import org.apache.doris.nereids.trees.expressions.WindowFrame.FrameBoundary;
+import org.apache.doris.nereids.trees.expressions.literal.LargeIntLiteral;
+import org.apache.doris.nereids.trees.plans.algebra.Window;
+
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Test;
+
+import java.math.BigDecimal;
+import java.math.BigInteger;
+import java.util.Collections;
+
+class AnalyticWindowTest {
+ @Test
+ void testNereidsRowsOffsetKeepsInt64Precision() {
+ Window window = Collections::emptyList;
+ FrameBoundary frameBoundary = FrameBoundary.newPrecedingBoundary(
+ new LargeIntLiteral(BigInteger.valueOf(Long.MAX_VALUE)));
+
+ AnalyticWindow.Boundary boundary =
window.withFrameBoundary(frameBoundary, null);
+
+ Assertions.assertEquals(Long.MAX_VALUE,
+
boundary.toThrift(AnalyticWindow.Type.ROWS).getRowsOffsetValue());
+ }
+
+ @Test
+ void testRowsOffsetOverMaxInt64IsRejected() {
+ BigDecimal offset =
BigDecimal.valueOf(Long.MAX_VALUE).add(BigDecimal.ONE);
+ for (AnalyticWindow.BoundaryType boundaryType : new
AnalyticWindow.BoundaryType[] {
+ AnalyticWindow.BoundaryType.PRECEDING,
AnalyticWindow.BoundaryType.FOLLOWING}) {
+ AnalyticWindow.Boundary boundary = new AnalyticWindow.Boundary(
+ boundaryType, new IntLiteral(1L), offset);
+
+ IllegalStateException exception =
Assertions.assertThrows(IllegalStateException.class,
+ () -> boundary.toThrift(AnalyticWindow.Type.ROWS));
+ Assertions.assertEquals("ROWS window offset must not exceed " +
Long.MAX_VALUE,
+ exception.getMessage());
+ }
+ }
+}
diff --git
a/fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/CheckAndStandardizeWindowFunctionTest.java
b/fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/CheckAndStandardizeWindowFunctionTest.java
index 2f3b133fdeb..2f01267140a 100644
---
a/fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/CheckAndStandardizeWindowFunctionTest.java
+++
b/fe/fe-core/src/test/java/org/apache/doris/nereids/rules/rewrite/CheckAndStandardizeWindowFunctionTest.java
@@ -239,7 +239,7 @@ public class CheckAndStandardizeWindowFunctionTest
implements MemoPatternMatchSu
WindowFrame windowFrame2 = new WindowFrame(FrameUnitsType.ROWS,
FrameBoundary.newFollowingBoundary(new IntegerLiteral(5)),
FrameBoundary.newFollowingBoundary(new IntegerLiteral(4)));
- String errorMsg2 = "WindowFrame with FOLLOWING boundary requires that
leftBoundOffset >= rightBoundOffset";
+ String errorMsg2 = "WindowFrame with FOLLOWING boundary requires that
leftBoundOffset <= rightBoundOffset";
forCheckWindowFrameBeforeFunc(windowFrame2, errorMsg2);
}
diff --git
a/fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/functions/window/LeadLagOffsetTest.java
b/fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/functions/window/LeadLagOffsetTest.java
new file mode 100644
index 00000000000..660de69208a
--- /dev/null
+++
b/fe/fe-core/src/test/java/org/apache/doris/nereids/trees/expressions/functions/window/LeadLagOffsetTest.java
@@ -0,0 +1,88 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements. See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership. The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied. See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+package org.apache.doris.nereids.trees.expressions.functions.window;
+
+import org.apache.doris.nereids.exceptions.AnalysisException;
+import org.apache.doris.nereids.trees.expressions.literal.BigIntLiteral;
+import org.apache.doris.nereids.trees.expressions.literal.DecimalV3Literal;
+import org.apache.doris.nereids.trees.expressions.literal.IntegerLiteral;
+import org.apache.doris.nereids.trees.expressions.literal.LargeIntLiteral;
+
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Test;
+
+import java.math.BigDecimal;
+import java.math.BigInteger;
+
+public class LeadLagOffsetTest {
+
+ private static final DecimalV3Literal NON_INTEGER_OFFSET =
+ new DecimalV3Literal(new BigDecimal("922337203685477580.1"));
+ private static final BigIntLiteral MAX_BIGINT_OFFSET = new
BigIntLiteral(Long.MAX_VALUE);
+ private static final LargeIntLiteral OVER_MAX_BIGINT_OFFSET =
+ new
LargeIntLiteral(BigInteger.valueOf(Long.MAX_VALUE).add(BigInteger.ONE));
+
+ @Test
+ public void testLagRejectsNonIntegerOffsetBeforeTypeCoercion() {
+ Lag lag = new Lag(new IntegerLiteral(1), NON_INTEGER_OFFSET);
+
+ AnalysisException exception = Assertions.assertThrows(
+ AnalysisException.class, lag::checkLegalityBeforeTypeCoercion);
+ Assertions.assertTrue(exception.getMessage().contains(
+ "The offset parameter of LAG must be a constant positive
integer"));
+ }
+
+ @Test
+ public void testLeadRejectsNonIntegerOffsetBeforeTypeCoercion() {
+ Lead lead = new Lead(new IntegerLiteral(1), NON_INTEGER_OFFSET);
+
+ AnalysisException exception = Assertions.assertThrows(
+ AnalysisException.class,
lead::checkLegalityBeforeTypeCoercion);
+ Assertions.assertTrue(exception.getMessage().contains(
+ "The offset parameter of LEAD must be a constant positive
integer"));
+ }
+
+ @Test
+ public void testLagRejectsOffsetOverMaxBigintBeforeTypeCoercion() {
+ Lag lag = new Lag(new IntegerLiteral(1), OVER_MAX_BIGINT_OFFSET);
+
+ AnalysisException exception = Assertions.assertThrows(
+ AnalysisException.class, lag::checkLegalityBeforeTypeCoercion);
+ Assertions.assertTrue(exception.getMessage().contains(
+ "The offset parameter of LAG must not exceed " +
Long.MAX_VALUE));
+ }
+
+ @Test
+ public void testLeadRejectsOffsetOverMaxBigintBeforeTypeCoercion() {
+ Lead lead = new Lead(new IntegerLiteral(1), OVER_MAX_BIGINT_OFFSET);
+
+ AnalysisException exception = Assertions.assertThrows(
+ AnalysisException.class,
lead::checkLegalityBeforeTypeCoercion);
+ Assertions.assertTrue(exception.getMessage().contains(
+ "The offset parameter of LEAD must not exceed " +
Long.MAX_VALUE));
+ }
+
+ @Test
+ public void testMaxBigintOffsetIsAcceptedBeforeTypeCoercion() {
+ Lag lag = new Lag(new IntegerLiteral(1), MAX_BIGINT_OFFSET);
+ Lead lead = new Lead(new IntegerLiteral(1), MAX_BIGINT_OFFSET);
+
+ Assertions.assertDoesNotThrow(lag::checkLegalityBeforeTypeCoercion);
+ Assertions.assertDoesNotThrow(lead::checkLegalityBeforeTypeCoercion);
+ }
+}
diff --git
a/regression-test/suites/query_p0/sql_functions/window_functions/test_lead_lag_large_offset.groovy
b/regression-test/suites/query_p0/sql_functions/window_functions/test_lead_lag_large_offset.groovy
new file mode 100644
index 00000000000..712c3f48da3
--- /dev/null
+++
b/regression-test/suites/query_p0/sql_functions/window_functions/test_lead_lag_large_offset.groovy
@@ -0,0 +1,292 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements. See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership. The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied. See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+suite("test_lead_lag_large_offset") {
+ sql "SET enable_nereids_planner = true"
+ sql "SET enable_fallback_to_original_planner = false"
+
+ /*
+ Note: offset value is not likely to be such big as 9223372036854775807,
+ so currently BE does not check for int64 overflow, and BE will crash:
+ ```
+../src/exec/operator/analytic_sink_operator.cpp:229:76: runtime error: signed
integer overflow: 9223372036854775807 + 1 cannot be represented in type
'int64_t' (aka 'long')
+ #0 0x55efa53c8f4f in
doris::AnalyticSinkLocalState::_get_next_for_unbounded_rows(long, long)
be/build_ASAN/../src/exec/operator/analytic_sink_operator.cpp:229:76
+ #1 0x55efa53d827a in
doris::AnalyticSinkLocalState::_execute_impl(doris::RuntimeState*)
be/build_ASAN/../src/exec/operator/analytic_sink_operator.cpp:358:33
+ #2 0x55efa53e9e33 in
doris::AnalyticSinkOperatorX::sink_impl(doris::RuntimeState*, doris::Block*,
bool) be/build_ASAN/../src/exec/operator/analytic_sink_operator.cpp:754:5
+ #3 0x55efa0a2b660 in
doris::DataSinkOperatorXBase::sink(doris::RuntimeState*, doris::Block*, bool)
be/build_ASAN/../src/exec/operator/operator.h:621:16
+ #4 0x55efa09f2649 in doris::PipelineTask::execute(bool*)
be/build_ASAN/../src/exec/pipeline/pipeline_task.cpp:726:29
+ #5 0x55efa85d9abf in doris::TaskScheduler::_do_work(int)
be/build_ASAN/../src/exec/pipeline/task_scheduler.cpp:151:13
+ #6 0x55efa85ddf3c in doris::TaskScheduler::start()::$_0::operator()()
const be/build_ASAN/../src/exec/pipeline/task_scheduler.cpp:64:9
+ #7 0x55efa85dde2c in void std::__invoke_impl<void,
doris::TaskScheduler::start()::$_0&>(std::__invoke_other,
doris::TaskScheduler::start()::$_0&)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/invoke.h:63:14
+ #8 0x55efa85ddd4c in std::enable_if<is_invocable_r_v<void,
doris::TaskScheduler::start()::$_0&>, void>::type std::__invoke_r<void,
doris::TaskScheduler::start()::$_0&>(doris::TaskScheduler::start()::$_0&)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/invoke.h:113:2
+ #9 0x55efa85dda24 in std::_Function_handler<void (),
doris::TaskScheduler::start()::$_0>::_M_invoke(std::_Any_data const&)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/std_function.h:292:9
+ #10 0x55ef7d4bf9ad in std::function<void ()>::operator()() const
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/std_function.h:593:9
+ #11 0x55efa9f150b0 in doris::FunctionRunnable::run()
be/build_ASAN/../src/util/threadpool.cpp:60:27
+ #12 0x55efa9ef6ced in doris::ThreadPool::dispatch_thread()
be/build_ASAN/../src/util/threadpool.cpp:621:24
+ #13 0x55efa9f356fc in void std::__invoke_impl<void, void
(doris::ThreadPool::*&)(), doris::ThreadPool*&>(std::__invoke_memfun_deref,
void (doris::ThreadPool::*&)(), doris::ThreadPool*&)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/invoke.h:76:14
+ #14 0x55efa9f354b4 in std::__invoke_result<void (doris::ThreadPool::*&)(),
doris::ThreadPool*&>::type std::__invoke<void (doris::ThreadPool::*&)(),
doris::ThreadPool*&>(void (doris::ThreadPool::*&)(), doris::ThreadPool*&)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/invoke.h:98:14
+ #15 0x55efa9f353e0 in void std::_Bind<void (doris::ThreadPool::*
(doris::ThreadPool*))()>::__call<void, 0ul>(std::tuple<>&&,
std::_Index_tuple<0ul>)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/functional:515:11
+ #16 0x55efa9f3519b in void std::_Bind<void (doris::ThreadPool::*
(doris::ThreadPool*))()>::operator()<void>()
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/functional:600:17
+ #17 0x55efa9f3508c in void std::__invoke_impl<void, std::_Bind<void
(doris::ThreadPool::* (doris::ThreadPool*))()>&>(std::__invoke_other,
std::_Bind<void (doris::ThreadPool::* (doris::ThreadPool*))()>&)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/invoke.h:63:14
+ #18 0x55efa9f34f8c in std::enable_if<is_invocable_r_v<void,
std::_Bind<void (doris::ThreadPool::* (doris::ThreadPool*))()>&>, void>::type
std::__invoke_r<void, std::_Bind<void (doris::ThreadPool::*
(doris::ThreadPool*))()>&>(std::_Bind<void (doris::ThreadPool::*
(doris::ThreadPool*))()>&)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/invoke.h:113:2
+ #19 0x55efa9f34864 in std::_Function_handler<void (), std::_Bind<void
(doris::ThreadPool::* (doris::ThreadPool*))()>>::_M_invoke(std::_Any_data
const&)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/std_function.h:292:9
+ #20 0x55ef7d4bf9ad in std::function<void ()>::operator()() const
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/std_function.h:593:9
+ #21 0x55efa9eafd98 in doris::Thread::supervise_thread(void*)
be/build_ASAN/../src/util/thread.cpp:460:5
+ #22 0x55ef7d205d26 in asan_thread_start(void*)
(/mnt/disk2/tengjianping/wt-master/wt-memleak3/output/be/lib/doris_be+0x4b80dd26)
+ #23 0x7f96c0c8b698 in start_thread (/lib64/libc.so.6+0x8b698) (BuildId:
65d7e434cec6326711148d1465614ba5c96649c1)
+ #24 0x7f96c0d1089f in __GI___clone3 (/lib64/libc.so.6+0x11089f) (BuildId:
65d7e434cec6326711148d1465614ba5c96649c1)
+
+SUMMARY: UndefinedBehaviorSanitizer: undefined-behavior
../src/exec/operator/analytic_sink_operator.cpp:229:76
+../src/exec/operator/analytic_sink_operator.cpp:240:77: runtime error: signed
integer overflow: -9223372036854775808 - 1 cannot be represented in type
'int64_t' (aka 'long')
+ #0 0x55efa53c96e5 in
doris::AnalyticSinkLocalState::_get_next_for_unbounded_rows(long, long)
be/build_ASAN/../src/exec/operator/analytic_sink_operator.cpp:240:77
+ #1 0x55efa53d827a in
doris::AnalyticSinkLocalState::_execute_impl(doris::RuntimeState*)
be/build_ASAN/../src/exec/operator/analytic_sink_operator.cpp:358:33
+ #2 0x55efa53e9e33 in
doris::AnalyticSinkOperatorX::sink_impl(doris::RuntimeState*, doris::Block*,
bool) be/build_ASAN/../src/exec/operator/analytic_sink_operator.cpp:754:5
+ #3 0x55efa0a2b660 in
doris::DataSinkOperatorXBase::sink(doris::RuntimeState*, doris::Block*, bool)
be/build_ASAN/../src/exec/operator/operator.h:621:16
+ #4 0x55efa09f2649 in doris::PipelineTask::execute(bool*)
be/build_ASAN/../src/exec/pipeline/pipeline_task.cpp:726:29
+ #5 0x55efa85d9abf in doris::TaskScheduler::_do_work(int)
be/build_ASAN/../src/exec/pipeline/task_scheduler.cpp:151:13
+ #6 0x55efa85ddf3c in doris::TaskScheduler::start()::$_0::operator()()
const be/build_ASAN/../src/exec/pipeline/task_scheduler.cpp:64:9
+ #7 0x55efa85dde2c in void std::__invoke_impl<void,
doris::TaskScheduler::start()::$_0&>(std::__invoke_other,
doris::TaskScheduler::start()::$_0&)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/invoke.h:63:14
+ #8 0x55efa85ddd4c in std::enable_if<is_invocable_r_v<void,
doris::TaskScheduler::start()::$_0&>, void>::type std::__invoke_r<void,
doris::TaskScheduler::start()::$_0&>(doris::TaskScheduler::start()::$_0&)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/invoke.h:113:2
+ #9 0x55efa85dda24 in std::_Function_handler<void (),
doris::TaskScheduler::start()::$_0>::_M_invoke(std::_Any_data const&)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/std_function.h:292:9
+ #10 0x55ef7d4bf9ad in std::function<void ()>::operator()() const
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/std_function.h:593:9
+ #11 0x55efa9f150b0 in doris::FunctionRunnable::run()
be/build_ASAN/../src/util/threadpool.cpp:60:27
+ #12 0x55efa9ef6ced in doris::ThreadPool::dispatch_thread()
be/build_ASAN/../src/util/threadpool.cpp:621:24
+ #13 0x55efa9f356fc in void std::__invoke_impl<void, void
(doris::ThreadPool::*&)(), doris::ThreadPool*&>(std::__invoke_memfun_deref,
void (doris::ThreadPool::*&)(), doris::ThreadPool*&)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/invoke.h:76:14
+ #14 0x55efa9f354b4 in std::__invoke_result<void (doris::ThreadPool::*&)(),
doris::ThreadPool*&>::type std::__invoke<void (doris::ThreadPool::*&)(),
doris::ThreadPool*&>(void (doris::ThreadPool::*&)(), doris::ThreadPool*&)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/invoke.h:98:14
+ #15 0x55efa9f353e0 in void std::_Bind<void (doris::ThreadPool::*
(doris::ThreadPool*))()>::__call<void, 0ul>(std::tuple<>&&,
std::_Index_tuple<0ul>)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/functional:515:11
+ #16 0x55efa9f3519b in void std::_Bind<void (doris::ThreadPool::*
(doris::ThreadPool*))()>::operator()<void>()
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/functional:600:17
+ #17 0x55efa9f3508c in void std::__invoke_impl<void, std::_Bind<void
(doris::ThreadPool::* (doris::ThreadPool*))()>&>(std::__invoke_other,
std::_Bind<void (doris::ThreadPool::* (doris::ThreadPool*))()>&)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/invoke.h:63:14
+ #18 0x55efa9f34f8c in std::enable_if<is_invocable_r_v<void,
std::_Bind<void (doris::ThreadPool::* (doris::ThreadPool*))()>&>, void>::type
std::__invoke_r<void, std::_Bind<void (doris::ThreadPool::*
(doris::ThreadPool*))()>&>(std::_Bind<void (doris::ThreadPool::*
(doris::ThreadPool*))()>&)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/invoke.h:113:2
+ #19 0x55efa9f34864 in std::_Function_handler<void (), std::_Bind<void
(doris::ThreadPool::* (doris::ThreadPool*))()>>::_M_invoke(std::_Any_data
const&)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/std_function.h:292:9
+ #20 0x55ef7d4bf9ad in std::function<void ()>::operator()() const
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/std_function.h:593:9
+ #21 0x55efa9eafd98 in doris::Thread::supervise_thread(void*)
be/build_ASAN/../src/util/thread.cpp:460:5
+ #22 0x55ef7d205d26 in asan_thread_start(void*)
(/mnt/disk2/tengjianping/wt-master/wt-memleak3/output/be/lib/doris_be+0x4b80dd26)
+ #23 0x7f96c0c8b698 in start_thread (/lib64/libc.so.6+0x8b698) (BuildId:
65d7e434cec6326711148d1465614ba5c96649c1)
+ #24 0x7f96c0d1089f in __GI___clone3 (/lib64/libc.so.6+0x11089f) (BuildId:
65d7e434cec6326711148d1465614ba5c96649c1)
+
+SUMMARY: UndefinedBehaviorSanitizer: undefined-behavior
../src/exec/operator/analytic_sink_operator.cpp:240:77
+../src/exec/operator/analytic_sink_operator.cpp:242:97: runtime error: signed
integer overflow: -9223372036854775808 - 1 cannot be represented in type
'int64_t' (aka 'long')
+ #0 0x55efa53c993a in
doris::AnalyticSinkLocalState::_get_next_for_unbounded_rows(long, long)
be/build_ASAN/../src/exec/operator/analytic_sink_operator.cpp:242:97
+ #1 0x55efa53d827a in
doris::AnalyticSinkLocalState::_execute_impl(doris::RuntimeState*)
be/build_ASAN/../src/exec/operator/analytic_sink_operator.cpp:358:33
+ #2 0x55efa53e9e33 in
doris::AnalyticSinkOperatorX::sink_impl(doris::RuntimeState*, doris::Block*,
bool) be/build_ASAN/../src/exec/operator/analytic_sink_operator.cpp:754:5
+ #3 0x55efa0a2b660 in
doris::DataSinkOperatorXBase::sink(doris::RuntimeState*, doris::Block*, bool)
be/build_ASAN/../src/exec/operator/operator.h:621:16
+ #4 0x55efa09f2649 in doris::PipelineTask::execute(bool*)
be/build_ASAN/../src/exec/pipeline/pipeline_task.cpp:726:29
+ #5 0x55efa85d9abf in doris::TaskScheduler::_do_work(int)
be/build_ASAN/../src/exec/pipeline/task_scheduler.cpp:151:13
+ #6 0x55efa85ddf3c in doris::TaskScheduler::start()::$_0::operator()()
const be/build_ASAN/../src/exec/pipeline/task_scheduler.cpp:64:9
+ #7 0x55efa85dde2c in void std::__invoke_impl<void,
doris::TaskScheduler::start()::$_0&>(std::__invoke_other,
doris::TaskScheduler::start()::$_0&)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/invoke.h:63:14
+ #8 0x55efa85ddd4c in std::enable_if<is_invocable_r_v<void,
doris::TaskScheduler::start()::$_0&>, void>::type std::__invoke_r<void,
doris::TaskScheduler::start()::$_0&>(doris::TaskScheduler::start()::$_0&)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/invoke.h:113:2
+ #9 0x55efa85dda24 in std::_Function_handler<void (),
doris::TaskScheduler::start()::$_0>::_M_invoke(std::_Any_data const&)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/std_function.h:292:9
+ #10 0x55ef7d4bf9ad in std::function<void ()>::operator()() const
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/std_function.h:593:9
+ #11 0x55efa9f150b0 in doris::FunctionRunnable::run()
be/build_ASAN/../src/util/threadpool.cpp:60:27
+ #12 0x55efa9ef6ced in doris::ThreadPool::dispatch_thread()
be/build_ASAN/../src/util/threadpool.cpp:621:24
+ #13 0x55efa9f356fc in void std::__invoke_impl<void, void
(doris::ThreadPool::*&)(), doris::ThreadPool*&>(std::__invoke_memfun_deref,
void (doris::ThreadPool::*&)(), doris::ThreadPool*&)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/invoke.h:76:14
+ #14 0x55efa9f354b4 in std::__invoke_result<void (doris::ThreadPool::*&)(),
doris::ThreadPool*&>::type std::__invoke<void (doris::ThreadPool::*&)(),
doris::ThreadPool*&>(void (doris::ThreadPool::*&)(), doris::ThreadPool*&)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/invoke.h:98:14
+ #15 0x55efa9f353e0 in void std::_Bind<void (doris::ThreadPool::*
(doris::ThreadPool*))()>::__call<void, 0ul>(std::tuple<>&&,
std::_Index_tuple<0ul>)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/functional:515:11
+ #16 0x55efa9f3519b in void std::_Bind<void (doris::ThreadPool::*
(doris::ThreadPool*))()>::operator()<void>()
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/functional:600:17
+ #17 0x55efa9f3508c in void std::__invoke_impl<void, std::_Bind<void
(doris::ThreadPool::* (doris::ThreadPool*))()>&>(std::__invoke_other,
std::_Bind<void (doris::ThreadPool::* (doris::ThreadPool*))()>&)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/invoke.h:63:14
+ #18 0x55efa9f34f8c in std::enable_if<is_invocable_r_v<void,
std::_Bind<void (doris::ThreadPool::* (doris::ThreadPool*))()>&>, void>::type
std::__invoke_r<void, std::_Bind<void (doris::ThreadPool::*
(doris::ThreadPool*))()>&>(std::_Bind<void (doris::ThreadPool::*
(doris::ThreadPool*))()>&)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/invoke.h:113:2
+ #19 0x55efa9f34864 in std::_Function_handler<void (), std::_Bind<void
(doris::ThreadPool::* (doris::ThreadPool*))()>>::_M_invoke(std::_Any_data
const&)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/std_function.h:292:9
+ #20 0x55ef7d4bf9ad in std::function<void ()>::operator()() const
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/std_function.h:593:9
+ #21 0x55efa9eafd98 in doris::Thread::supervise_thread(void*)
be/build_ASAN/../src/util/thread.cpp:460:5
+ #22 0x55ef7d205d26 in asan_thread_start(void*)
(/mnt/disk2/tengjianping/wt-master/wt-memleak3/output/be/lib/doris_be+0x4b80dd26)
+ #23 0x7f96c0c8b698 in start_thread (/lib64/libc.so.6+0x8b698) (BuildId:
65d7e434cec6326711148d1465614ba5c96649c1)
+ #24 0x7f96c0d1089f in __GI___clone3 (/lib64/libc.so.6+0x11089f) (BuildId:
65d7e434cec6326711148d1465614ba5c96649c1)
+
+SUMMARY: UndefinedBehaviorSanitizer: undefined-behavior
../src/exec/operator/analytic_sink_operator.cpp:242:97
+../src/exprs/aggregate/aggregate_function_window.h:512:44: runtime error:
signed integer overflow: -9223372036854775808 - 1 cannot be represented in type
'int64_t' (aka 'long')
+ #0 0x55ef89702528 in
doris::WindowFunctionLeadImpl<doris::LeadLagData<true, false>,
false>::add_range_single_place(long, long, long, long, doris::IColumn const**)
be/build_ASAN/../src/exprs/aggregate/aggregate_function_window.h:512:44
+ #1 0x55ef896f9914 in
doris::WindowFunctionData<doris::WindowFunctionLeadImpl<doris::LeadLagData<true,
false>, false>>::add_range_single_place(long, long, long, long, char*,
doris::IColumn const**, doris::Arena&, unsigned char*, unsigned char*) const
be/build_ASAN/../src/exprs/aggregate/aggregate_function_window.h:674:27
+ #2 0x55efa542f314 in doris::AggFnEvaluator::add_range_single_place(long,
long, long, long, char*, doris::IColumn const**, doris::Arena&, unsigned char*,
unsigned char*) be/build_ASAN/../src/exprs/vectorized_agg_fn.cpp:325:16
+ #3 0x55efa5402ce6 in void
doris::AnalyticSinkLocalState::_execute_for_function<false>(long, long, long,
long) be/build_ASAN/../src/exec/operator/analytic_sink_operator.cpp:391:32
+ #4 0x55efa53c995c in
doris::AnalyticSinkLocalState::_get_next_for_unbounded_rows(long, long)
be/build_ASAN/../src/exec/operator/analytic_sink_operator.cpp:242:9
+ #5 0x55efa53d827a in
doris::AnalyticSinkLocalState::_execute_impl(doris::RuntimeState*)
be/build_ASAN/../src/exec/operator/analytic_sink_operator.cpp:358:33
+ #6 0x55efa53e9e33 in
doris::AnalyticSinkOperatorX::sink_impl(doris::RuntimeState*, doris::Block*,
bool) be/build_ASAN/../src/exec/operator/analytic_sink_operator.cpp:754:5
+ #7 0x55efa0a2b660 in
doris::DataSinkOperatorXBase::sink(doris::RuntimeState*, doris::Block*, bool)
be/build_ASAN/../src/exec/operator/operator.h:621:16
+ #8 0x55efa09f2649 in doris::PipelineTask::execute(bool*)
be/build_ASAN/../src/exec/pipeline/pipeline_task.cpp:726:29
+ #9 0x55efa85d9abf in doris::TaskScheduler::_do_work(int)
be/build_ASAN/../src/exec/pipeline/task_scheduler.cpp:151:13
+ #10 0x55efa85ddf3c in doris::TaskScheduler::start()::$_0::operator()()
const be/build_ASAN/../src/exec/pipeline/task_scheduler.cpp:64:9
+ #11 0x55efa85dde2c in void std::__invoke_impl<void,
doris::TaskScheduler::start()::$_0&>(std::__invoke_other,
doris::TaskScheduler::start()::$_0&)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/invoke.h:63:14
+ #12 0x55efa85ddd4c in std::enable_if<is_invocable_r_v<void,
doris::TaskScheduler::start()::$_0&>, void>::type std::__invoke_r<void,
doris::TaskScheduler::start()::$_0&>(doris::TaskScheduler::start()::$_0&)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/invoke.h:113:2
+ #13 0x55efa85dda24 in std::_Function_handler<void (),
doris::TaskScheduler::start()::$_0>::_M_invoke(std::_Any_data const&)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/std_function.h:292:9
+ #14 0x55ef7d4bf9ad in std::function<void ()>::operator()() const
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/std_function.h:593:9
+ #15 0x55efa9f150b0 in doris::FunctionRunnable::run()
be/build_ASAN/../src/util/threadpool.cpp:60:27
+ #16 0x55efa9ef6ced in doris::ThreadPool::dispatch_thread()
be/build_ASAN/../src/util/threadpool.cpp:621:24
+ #17 0x55efa9f356fc in void std::__invoke_impl<void, void
(doris::ThreadPool::*&)(), doris::ThreadPool*&>(std::__invoke_memfun_deref,
void (doris::ThreadPool::*&)(), doris::ThreadPool*&)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/invoke.h:76:14
+ #18 0x55efa9f354b4 in std::__invoke_result<void (doris::ThreadPool::*&)(),
doris::ThreadPool*&>::type std::__invoke<void (doris::ThreadPool::*&)(),
doris::ThreadPool*&>(void (doris::ThreadPool::*&)(), doris::ThreadPool*&)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/invoke.h:98:14
+ #19 0x55efa9f353e0 in void std::_Bind<void (doris::ThreadPool::*
(doris::ThreadPool*))()>::__call<void, 0ul>(std::tuple<>&&,
std::_Index_tuple<0ul>)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/functional:515:11
+ #20 0x55efa9f3519b in void std::_Bind<void (doris::ThreadPool::*
(doris::ThreadPool*))()>::operator()<void>()
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/functional:600:17
+ #21 0x55efa9f3508c in void std::__invoke_impl<void, std::_Bind<void
(doris::ThreadPool::* (doris::ThreadPool*))()>&>(std::__invoke_other,
std::_Bind<void (doris::ThreadPool::* (doris::ThreadPool*))()>&)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/invoke.h:63:14
+ #22 0x55efa9f34f8c in std::enable_if<is_invocable_r_v<void,
std::_Bind<void (doris::ThreadPool::* (doris::ThreadPool*))()>&>, void>::type
std::__invoke_r<void, std::_Bind<void (doris::ThreadPool::*
(doris::ThreadPool*))()>&>(std::_Bind<void (doris::ThreadPool::*
(doris::ThreadPool*))()>&)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/invoke.h:113:2
+ #23 0x55efa9f34864 in std::_Function_handler<void (), std::_Bind<void
(doris::ThreadPool::* (doris::ThreadPool*))()>>::_M_invoke(std::_Any_data
const&)
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/std_function.h:292:9
+ #24 0x55ef7d4bf9ad in std::function<void ()>::operator()() const
/mnt/disk2/tengjianping/local/ldb_toolchain/bin/../lib/gcc/x86_64-pc-linux-gnu/15/include/g++-v15/bits/std_function.h:593:9
+ #25 0x55efa9eafd98 in doris::Thread::supervise_thread(void*)
be/build_ASAN/../src/util/thread.cpp:460:5
+ #26 0x55ef7d205d26 in asan_thread_start(void*)
(/mnt/disk2/tengjianping/wt-master/wt-memleak3/output/be/lib/doris_be+0x4b80dd26)
+ #27 0x7f96c0c8b698 in start_thread (/lib64/libc.so.6+0x8b698) (BuildId:
65d7e434cec6326711148d1465614ba5c96649c1)
+ #28 0x7f96c0d1089f in __GI___clone3 (/lib64/libc.so.6+0x11089f) (BuildId:
65d7e434cec6326711148d1465614ba5c96649c1)
+
+SUMMARY: UndefinedBehaviorSanitizer: undefined-behavior
../src/exprs/aggregate/aggregate_function_window.h:512:44
+F 2026-07-27 11:47:15,677 252267 pod_array.h:370] Check failed: n <=
static_cast<ssize_t>(this->size()) (9223372036854775807 vs. 2)
+*** Check failure stack trace: ***
+ @ 0x55efaefc1366 google::LogMessageFatal::~LogMessageFatal()
+ @ 0x55ef7ec42fe8 doris::PODArray<>::operator[]()
+ @ 0x55ef7ed21415 doris::ColumnVector<>::get_data_at()
+ @ 0x55ef896d7ada doris::BaseValue<>::get_value()
+ @ 0x55ef897010b3 doris::LeadLagData<>::insert_result_into()
+ @ 0x55ef896f86d4 doris::WindowFunctionData<>::insert_result_into()
+ @ 0x55ef815c7d46 doris::IAggregateFunction::insert_result_into_range()
+ @ 0x55efa5430265 doris::AggFnEvaluator::insert_result_info_range()
+ @ 0x55efa53d4467 doris::AnalyticSinkLocalState::_insert_result_info()
+ @ 0x55efa53c9a81
doris::AnalyticSinkLocalState::_get_next_for_unbounded_rows()
+ @ 0x55efa53d827b doris::AnalyticSinkLocalState::_execute_impl()
+ @ 0x55efa53e9e34 doris::AnalyticSinkOperatorX::sink_impl()
+ @ 0x55efa0a2b661 doris::DataSinkOperatorXBase::sink()
+ @ 0x55efa09f264a doris::PipelineTask::execute()
+ @ 0x55efa85d9ac0 doris::TaskScheduler::_do_work()
+ @ 0x55efa85ddf3d doris::TaskScheduler::start()::$_0::operator()()
+ @ 0x55efa85dde2d std::__invoke_impl<>()
+ @ 0x55efa85ddd4d
_ZSt10__invoke_rIvRZN5doris13TaskScheduler5startEvE3$_0JEENSt9enable_ifIX16is_invocable_r_vIT_T0_DpT1_EES5_E4typeEOS6_DpOS7_
+ @ 0x55efa85dda25 std::_Function_handler<>::_M_invoke()
+ @ 0x55ef7d4bf9ae std::function<>::operator()()
+ @ 0x55efa9f150b1 doris::FunctionRunnable::run()
+ @ 0x55efa9ef6cee doris::ThreadPool::dispatch_thread()
+ @ 0x55efa9f356fd std::__invoke_impl<>()
+ @ 0x55efa9f354b5 std::__invoke<>()
+ @ 0x55efa9f353e1
_ZNSt5_BindIFMN5doris10ThreadPoolEFvvEPS1_EE6__callIvJEJLm0EEEET_OSt5tupleIJDpT0_EESt12_Index_tupleIJXspT1_EEE
+ @ 0x55efa9f3519c std::_Bind<>::operator()<>()
+ @ 0x55efa9f3508d std::__invoke_impl<>()
+ @ 0x55efa9f34f8d
_ZSt10__invoke_rIvRSt5_BindIFMN5doris10ThreadPoolEFvvEPS2_EEJEENSt9enable_ifIX16is_invocable_r_vIT_T0_DpT1_EESA_E4typeEOSB_DpOSC_
+ @ 0x55efa9f34865 std::_Function_handler<>::_M_invoke()
+ @ 0x55ef7d4bf9ae std::function<>::operator()()
+ @ 0x55efa9eafd99 doris::Thread::supervise_thread()
+ @ 0x55ef7d205d27 asan_thread_start()
+*** Query id: 8689a709882f431d-9c24d9d0d8a35473 ***
+*** tablet id: 0 ***
+*** Aborted at 1785124036 (unix time) try "date -d @1785124036" if you are
using GNU date ***
+*** Current BE git commitID: 5e673d5a4a3 ***
+*** SIGABRT unknown detail explain (@0x3eb0003c20c) received by PID 246284
(TID 252267 OR 0x77fbc810d640) from PID 246284; stack trace: ***
+ 0# doris::signal::(anonymous namespace)::FailureSignalHandler(int,
siginfo_t*, void*) at ../src/common/signal_handler.h:417
+ 1# 0x00007F96C0C3FC60 in /lib64/libc.so.6
+ 2# __pthread_kill_implementation in /lib64/libc.so.6
+ 3# gsignal in /lib64/libc.so.6
+ 4# abort in /lib64/libc.so.6
+ 5# 0x000055EFAEFC8CED in
/mnt/disk2/tengjianping/wt-master/wt-memleak3/output/be/lib/doris_be
+ 6# google::LogMessage::SendToLog() in
/mnt/disk2/tengjianping/wt-master/wt-memleak3/output/be/lib/doris_be
+ 7# google::LogMessage::Flush() in
/mnt/disk2/tengjianping/wt-master/wt-memleak3/output/be/lib/doris_be
+ 8# google::LogMessageFatal::~LogMessageFatal() in
/mnt/disk2/tengjianping/wt-master/wt-memleak3/output/be/lib/doris_be
+ 9# doris::PODArray<signed char, 4096ul, doris::Allocator<false, false, false,
doris::DefaultMemoryAllocator, true>, 16ul, 15ul>::operator[](long) const at
../src/core/pod_array.h:370
+10# doris::ColumnVector<(doris::PrimitiveType)3>::get_data_at(unsigned long)
const at ../src/core/column/column_vector.h:102
+11# doris::BaseValue<false>::get_value() const at
../src/exprs/aggregate/aggregate_function_window.h:426
+12# doris::LeadLagData<true, false>::insert_result_into(doris::IColumn&) const
at ../src/exprs/aggregate/aggregate_function_window.h:446
+13#
doris::WindowFunctionData<doris::WindowFunctionLeadImpl<doris::LeadLagData<true,
false>, false> >::insert_result_into(char const*, doris::IColumn&) const at
../src/exprs/aggregate/aggregate_function_window.h:682
+14# doris::IAggregateFunction::insert_result_into_range(char const*,
doris::IColumn&, unsigned long, unsigned long) const at
../src/exprs/aggregate/aggregate_function.h:270
+15# doris::AggFnEvaluator::insert_result_info_range(char const*,
doris::IColumn*, unsigned long, unsigned long) at
./be/build_ASAN/../src/exprs/vectorized_agg_fn.cpp:354
+16# doris::AnalyticSinkLocalState::_insert_result_info(long, long) at
./be/build_ASAN/../src/exec/operator/analytic_sink_operator.cpp:419
+17# doris::AnalyticSinkLocalState::_get_next_for_unbounded_rows(long, long) at
./be/build_ASAN/../src/exec/operator/analytic_sink_operator.cpp:245
+18# doris::AnalyticSinkLocalState::_execute_impl(doris::RuntimeState*) at
./be/build_ASAN/../src/exec/operator/analytic_sink_operator.cpp:358
+19# doris::AnalyticSinkOperatorX::sink_impl(doris::RuntimeState*,
doris::Block*, bool) at
./be/build_ASAN/../src/exec/operator/analytic_sink_operator.cpp:754
+20# doris::DataSinkOperatorXBase::sink(doris::RuntimeState*, doris::Block*,
bool) in /mnt/disk2/tengjianping/wt-master/wt-memleak3/output/be/lib/doris_be
+21# doris::PipelineTask::execute(bool*) at
./be/build_ASAN/../src/exec/pipeline/pipeline_task.cpp:726
+22# doris::TaskScheduler::_do_work(int) at
./be/build_ASAN/../src/exec/pipeline/task_scheduler.cpp:151
+ ```
+ // RQG test cases
+ order_qt_lead_max_int64 """
+ SELECT k, LEAD(k, 9223372036854775807) OVER (ORDER BY k) AS lag_big
+ FROM (SELECT 1 AS k UNION ALL SELECT 2) t
+ """
+
+ order_qt_lag_max_int64 """
+ SELECT k, LAG(k, 9223372036854775807) OVER (ORDER BY k) AS lag_big
+ FROM (SELECT 1 AS k UNION ALL SELECT 2) t
+ """
+
+ order_qt_lag_max_int64_with_default """
+ SELECT k, LAG(k, 9223372036854775807, k * 10) OVER (ORDER BY k) AS
lag_big
+ FROM (SELECT 1 AS k UNION ALL SELECT 2) t
+ """
+
+ multi_sql """
+ DROP TABLE IF EXISTS tmp_window_offset_extreme_probe;
+ CREATE TABLE tmp_window_offset_extreme_probe (
+ k INT
+ )
+ DUPLICATE KEY(k)
+ DISTRIBUTED BY HASH(k) BUCKETS 1
+ PROPERTIES('replication_num'='1');
+
+ INSERT INTO tmp_window_offset_extreme_probe VALUES (1), (2), (3);
+ """
+ order_qt_lead_big_int64 """
+ SELECT k,
+ LEAD(k, 9223372036854775800) OVER(ORDER BY k) AS lead_near
+ FROM tmp_window_offset_extreme_probe
+ """
+ */
+
+ test {
+ sql """
+ SELECT k, SUM(k) OVER (
+ ORDER BY k ROWS BETWEEN 9223372036854775808 PRECEDING AND
CURRENT ROW
+ ) AS sum_big
+ FROM (SELECT 1 AS k UNION ALL SELECT 2) t
+ """
+ exception "BoundOffset of ROWS WindowFrame must not exceed
9223372036854775807"
+ }
+
+ ["'abc'", "NULL", "TRUE", "DATE '2026-07-27'"].each { invalidOffset ->
+ test {
+ sql """
+ SELECT k, SUM(k) OVER (
+ ORDER BY k ROWS BETWEEN ${invalidOffset} PRECEDING AND
CURRENT ROW
+ ) AS sum_invalid_offset
+ FROM (SELECT 1 AS k UNION ALL SELECT 2) t
+ """
+ exception "BoundOffset of ROWS WindowFrame must be an Integer"
+ }
+ }
+
+ test {
+ sql """
+ SELECT k, LAG(k, 9223372036854775808) OVER (ORDER BY k) AS lag_big
+ FROM (SELECT 1 AS k UNION ALL SELECT 2) t
+ """
+ exception "The offset parameter of LAG must not exceed
9223372036854775807"
+ }
+
+ test {
+ sql """
+ SELECT k, LEAD(k, 9223372036854775808) OVER (ORDER BY k) AS
lead_big
+ FROM (SELECT 1 AS k UNION ALL SELECT 2) t
+ """
+ exception "The offset parameter of LEAD must not exceed
9223372036854775807"
+ }
+
+ test {
+ sql """
+ SELECT k, LAG(k, 922337203685477580.1) OVER (ORDER BY k) AS lag_big
+ FROM (SELECT 1 AS k UNION ALL SELECT 2) t
+ """
+ exception "The offset parameter of LAG must be a constant positive
integer"
+ }
+
+ test {
+ sql """
+ SELECT k, LEAD(k, 922337203685477580.1) OVER (ORDER BY k) AS
lead_big
+ FROM (SELECT 1 AS k UNION ALL SELECT 2) t
+ """
+ exception "The offset parameter of LEAD must be a constant positive
integer"
+ }
+}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
