Skip to content

Commit 3b56819

Browse files
remove copy
1 parent 36787f9 commit 3b56819

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/io/storage/HoodieSparkLanceWriter.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -114,26 +114,26 @@ public void writeRowWithMetadata(HoodieKey key, InternalRow row) throws IOExcept
114114
if (populateMetaFields) {
115115
UTF8String recordKey = UTF8String.fromString(key.getRecordKey());
116116
updateRecordMetadata(row, recordKey, key.getPartitionPath(), getWrittenRecordCount());
117-
super.write(row.copy());
117+
super.write(row);
118118
} else {
119-
super.write(row.copy());
119+
super.write(row);
120120
}
121121
}
122122

123123
@Override
124124
public void writeRow(String recordKey, InternalRow row) throws IOException {
125-
super.write(row.copy());
125+
super.write(row);
126126
}
127127

128128
@Override
129129
public void writeRow(UTF8String key, InternalRow row) throws IOException {
130130
// Key reserved for future bloom filter support (https://github.com/apache/hudi/issues/17664)
131-
super.write(row.copy());
131+
super.write(row);
132132
}
133133

134134
@Override
135135
public void writeRow(InternalRow row) throws IOException {
136-
super.write(row.copy());
136+
super.write(row);
137137
}
138138

139139
@Override

0 commit comments

Comments
 (0)