Change the default checksum to match hadoop fs

Although CRC32 is the default in the proto definitions, the java client sets it to CRC32C.
realab · Jul 11, 2023 · 325f0cf · 325f0cf
1 parent 77b16e0
commit 325f0cf
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/internal/transfer/block_writer.go b/internal/transfer/block_writer.go
@@ -218,7 +218,7 @@ func (bw *BlockWriter) writeBlockWriteRequest(w io.Writer) error {
 		MaxBytesRcvd:          proto.Uint64(uint64(bw.Offset)),
 		LatestGenerationStamp: proto.Uint64(uint64(bw.generationTimestamp())),
 		RequestedChecksum: &hdfs.ChecksumProto{
-			Type:             hdfs.ChecksumTypeProto_CHECKSUM_CRC32.Enum(),
+			Type:             hdfs.ChecksumTypeProto_CHECKSUM_CRC32C.Enum(),
 			BytesPerChecksum: proto.Uint32(outboundChunkSize),
 		},
 	}