oops

Author: KaiSernLim

internal/venice-common/src/main/java/com/linkedin/venice/kafka/validation/Segment.java

@@ -428,7 +428,6 @@ public ProducerPartitionState toProducerPartitionState() {
      */
     pps.aggregates = CollectionUtils.substituteEmptyMap(getAggregates());
     pps.debugInfo = CollectionUtils.substituteEmptyMap(getDebugInfo());
-    pps.checksumType = getCheckSumType().getValue();
     populateProducerPartitionState(pps);
     return pps;
   }
@@ -439,6 +438,7 @@ public void populateProducerPartitionState(ProducerPartitionState pps) {
      * which is expensive. We should only invoke this closure when necessary.
      */
     pps.checksumState = ByteBuffer.wrap(getCheckSumState());
+    pps.checksumType = getCheckSumType().getValue();
     pps.segmentNumber = getSegmentNumber();
     pps.messageSequenceNumber = getSequenceNumber();
     pps.messageTimestamp = getLastRecordProducerTimestamp();