@@ -67,7 +67,7 @@ std::string construct_sub_predicate(const TCondition& condition) {
 }
 
 // make operators from FE adaptive to BE
-std::string trans_op(const std::string& opt) {
+std::string trans_op(const std::string& opt, const std::string& condition_value = "") {
     std::string op = string(opt);
     if (op == "<") {
         op += "<";
@@ -79,6 +79,8 @@ std::string trans_op(const std::string& opt) {
             op = "=";
         } else if (op == "!*=") {
             op = "!=";
+        } else if (op == "<=>") {
+            op = iequal(condition_value, "NULL") ? "IS" : "=";
         }
     }
     return op;
@@ -296,7 +298,7 @@ Status DeleteHandler::parse_condition(const DeleteSubPredicatePB& sub_cond, TCon
         condition->column_unique_id = sub_cond.column_unique_id();
     }
     condition->column_name = sub_cond.column_name();
-    condition->condition_op = sub_cond.op();
+    condition->condition_op = trans_op(sub_cond.op(), sub_cond.cond_value());
     condition->condition_values.push_back(sub_cond.cond_value());
     return Status::OK();
 }
 
@@ -0,0 +1,4 @@
+-- This file is automatically generated. You should know what you did if you want to edit this
+-- !after_delete --
+2	20
+
@@ -0,0 +1,55 @@
+// 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_delete_nullsafe_eq", "delete_p0") {
+    def dbName = "repro_db_delete_nullsafe_eq"
+    def tableName = "t_core"
+
+    sql """ DROP DATABASE IF EXISTS ${dbName} """
+    sql """ CREATE DATABASE ${dbName} """
+    sql """ USE ${dbName} """
+
+    try {
+        sql """
+            CREATE TABLE ${tableName} (
+              k1 INT,
+              v1 INT
+            )
+            DUPLICATE KEY(k1)
+            PARTITION BY RANGE(k1) (
+              PARTITION p1 VALUES LESS THAN ("100")
+            )
+            DISTRIBUTED BY HASH(k1) BUCKETS 1
+            PROPERTIES(
+              "replication_num" = "1",
+              "disable_auto_compaction" = "true"
+            )
+        """
+
+        sql """ INSERT INTO ${tableName}(k1, v1) VALUES (1, 10) """
+        sql """ INSERT INTO ${tableName}(k1, v1) VALUES (2, 20) """
+
+        sql """ set delete_without_partition = true """
+        sql """ DELETE FROM ${tableName} WHERE k1 <=> 1 """
+        sql """ sync """
+
+        qt_after_delete """ SELECT * FROM ${tableName} ORDER BY k1 """
+    } finally {
+        sql """ set delete_without_partition = false """
+        sql """ DROP DATABASE IF EXISTS ${dbName} """
+    }
+}
Original file line number	Diff line number	Diff line change
`@@ -67,7 +67,7 @@ std::string construct_sub_predicate(const TCondition& condition) {`
`67`	`67`	`}`
`68`	`68`
`69`	`69`	`// make operators from FE adaptive to BE`
`70`		`-std::string trans_op(const std::string& opt) {`
	`70`	`+std::string trans_op(const std::string& opt, const std::string& condition_value = "") {`
`71`	`71`	`std::string op = string(opt);`
`72`	`72`	`if (op == "<") {`
`73`	`73`	`op += "<";`
`@@ -79,6 +79,8 @@ std::string trans_op(const std::string& opt) {`
`79`	`79`	`op = "=";`
`80`	`80`	`} else if (op == "!*=") {`
`81`	`81`	`op = "!=";`
	`82`	`+ } else if (op == "<=>") {`
	`83`	`+ op = iequal(condition_value, "NULL") ? "IS" : "=";`
`82`	`84`	`}`
`83`	`85`	`}`
`84`	`86`	`return op;`
`@@ -296,7 +298,7 @@ Status DeleteHandler::parse_condition(const DeleteSubPredicatePB& sub_cond, TCon`
`296`	`298`	`condition->column_unique_id = sub_cond.column_unique_id();`
`297`	`299`	`}`
`298`	`300`	`condition->column_name = sub_cond.column_name();`
`299`		`- condition->condition_op = sub_cond.op();`
	`301`	`+ condition->condition_op = trans_op(sub_cond.op(), sub_cond.cond_value());`
`300`	`302`	`condition->condition_values.push_back(sub_cond.cond_value());`
`301`	`303`	`return Status::OK();`
`302`	`304`	`}`
-Original file line number
+Diff line change
@@ @@ -0,0 +1,4 @@ @@
 +-- This file is automatically generated. You should know what you did if you want to edit this
 +-- !after_delete --
 +2	20
++