diff --git a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteRowDataFunction.java b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteRowDataFunction.java
index ae1c9e25f218..f11c61e5fcae 100644
--- a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteRowDataFunction.java
+++ b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteRowDataFunction.java
@@ -86,7 +86,7 @@ public void processElement(I record,
       payload = payloadCreation.createPayload(gr);
     }
     // [HUDI-8968] Use operationType uniformly instead of instantTime
-    HoodieOperation operation = HoodieOperation.fromName(record.getInstantTime());
+    HoodieOperation operation = HoodieOperation.fromValue(row.getRowKind().toByteValue());
     HoodieRecord hoodieRecord = new HoodieAvroRecord<>(hoodieKey, payload, operation);
 
     hoodieRecord.unseal();