diff --git a/processing/src/main/java/io/druid/segment/IndexIO.java b/processing/src/main/java/io/druid/segment/IndexIO.java index 036b5bf0d8d..0888abd8c87 100644 --- a/processing/src/main/java/io/druid/segment/IndexIO.java +++ b/processing/src/main/java/io/druid/segment/IndexIO.java @@ -253,6 +253,12 @@ public class IndexIO IndexableAdapter adapter2 ) { + if(rb1.getTimestamp() != rb2.getTimestamp()){ + throw new SegmentValidationException( + "Timestamp mismatch. Expected %d found %d", + rb1.getTimestamp(), rb2.getTimestamp() + ); + } final int[][] dims1 = rb1.getDims(); final int[][] dims2 = rb2.getDims(); if (dims1.length != dims2.length) {