Fix write into non bucket indexed table with changelog.enabled

apache · Feb 11, 2025 · 04a23b3 · 04a23b3
1 parent 3950556
commit 04a23b3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteRowDataFunction.java b/...-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();