From 04a23b31b7ad8b411c08a40715f48bcdc3ca657d Mon Sep 17 00:00:00 2001
From: Geser Dugarov <geserdugarov@gmail.com>
Date: Tue, 11 Feb 2025 18:14:37 +0700
Subject: [PATCH] Fix write into non bucket indexed table with
 `changelog.enabled`

---
 .../java/org/apache/hudi/sink/StreamWriteRowDataFunction.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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();