Update OlapTableSink.java

Signed-off-by: meegoo <[email protected]>
StarRocks · Feb 14, 2025 · a063100 · a063100
1 parent 2fa0220
commit a063100
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/fe/fe-core/src/main/java/com/starrocks/planner/OlapTableSink.java b/fe/fe-core/src/main/java/com/starrocks/planner/OlapTableSink.java
@@ -234,7 +234,7 @@ public void setIsFromOverwrite(boolean isFromOverwrite) {
         this.isFromOverwrite = isFromOverwrite;
     }
 
-    public void complete(String mergeCondition) throws StarRocksException {
+    public void complete(String mergeCondition) throws UserException {
         TOlapTableSink tSink = tDataSink.getOlap_table_sink();
         if (mergeCondition != null && !mergeCondition.isEmpty()) {
             tSink.setMerge_condition(mergeCondition);