Skip to content

Commit 6a13dd1

Browse files
committed
fix case
1 parent 0a8267d commit 6a13dd1

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

fe/fe-core/src/main/java/org/apache/doris/nereids/load/NereidsLoadUtils.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -202,8 +202,12 @@ public static LogicalPlan createLoadPlan(NereidsFileGroupInfo fileGroupInfo, Par
202202
CascadesContext cascadesContext = CascadesContext.initContext(new StatementContext(), currentRootPlan,
203203
PhysicalProperties.ANY);
204204
ConnectContext ctx = cascadesContext.getConnectContext();
205+
// we force convert nullable column to non-nullable column for load
206+
// so set feDebug to false to avoid AdjustNullableRule report error
207+
boolean oldFeDebugValue = ctx.getSessionVariable().feDebug;
205208
try {
206209
ctx.getSessionVariable().setDebugSkipFoldConstant(true);
210+
ctx.getSessionVariable().feDebug = false;
207211

208212
Analyzer.buildCustomAnalyzer(cascadesContext, ImmutableList.of(Analyzer.bottomUp(
209213
new BindExpression(),
@@ -240,6 +244,7 @@ public static LogicalPlan createLoadPlan(NereidsFileGroupInfo fileGroupInfo, Par
240244
throw new UserException(exception.getMessage());
241245
} finally {
242246
ctx.getSessionVariable().setDebugSkipFoldConstant(false);
247+
ctx.getSessionVariable().feDebug = oldFeDebugValue;
243248
}
244249

245250
return (LogicalPlan) cascadesContext.getRewritePlan();

0 commit comments

Comments
 (0)