Skip to content

Commit

Permalink
checkstyle
Browse files Browse the repository at this point in the history
  • Loading branch information
924060929 committed Jul 1, 2024
1 parent b991d39 commit 6a4b87f
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -602,8 +602,8 @@ public Optional<ResultSet> handleQueryInFe(StatementBase parsedStmt) {
}
}

if (physicalPlan instanceof PhysicalResultSink &&
physicalPlan.child(0) instanceof PhysicalHashAggregate && !getScanNodes().isEmpty()
if (physicalPlan instanceof PhysicalResultSink
&& physicalPlan.child(0) instanceof PhysicalHashAggregate && !getScanNodes().isEmpty()
&& getScanNodes().get(0) instanceof IcebergScanNode) {
List<Column> columns = Lists.newArrayList();
NamedExpression output = physicalPlan.getOutput().get(0);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1962,7 +1962,6 @@ public void executeAndSendResult(boolean isOutfileQuery, boolean isSendFields,
Cache cache = cacheAnalyzer.getCache();
if (cache instanceof SqlCache && !cache.isDisableCache() && planner instanceof NereidsPlanner) {
String originStmt = parsedStmt.getOrigStmt().originStmt;
LogicalPlanAdapter logicalPlanAdapter = (LogicalPlanAdapter) queryStmt;
context.getEnv().getSqlCacheManager().tryAddBeCache(context, originStmt, cacheAnalyzer);
}
}
Expand Down

0 comments on commit 6a4b87f

Please sign in to comment.