cherry-pick [AMORO-2091] Resolve the optimzing exception for KeyedTab…

…le with Timestamp(without zone) column as Primary key (apache#2095) using InternalRecordWrapper to build PrimaryKeyData for NodeFilter
shendanfengg · Oct 16, 2023 · e3c1e55 · e3c1e55
1 parent 045e155
commit e3c1e55
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/core/src/main/java/com/netease/arctic/io/reader/ArcticDeleteFilter.java b/core/src/main/java/com/netease/arctic/io/reader/ArcticDeleteFilter.java
@@ -144,7 +144,8 @@ protected ArcticDeleteFilter(
     deleteIds.add(MetadataColumns.FILE_OFFSET_FILED.fieldId());
     this.deleteSchema = TypeUtil.select(requiredSchema, deleteIds);
     if (sourceNodes != null) {
-      this.deleteNodeFilter = new NodeFilter<>(sourceNodes, deleteSchema, primaryKeySpec, record -> record);
+      this.deleteNodeFilter = new NodeFilter<>(sourceNodes, deleteSchema, primaryKeySpec,
+          record -> new InternalRecordWrapper(deleteSchema.asStruct()).wrap(record));
     } else {
       this.deleteNodeFilter = null;
     }