From 63b5c8653f9b5f89e99ba6921ddca253269be49b Mon Sep 17 00:00:00 2001
From: T45K <tasktas9@gmail.com>
Date: Tue, 22 Sep 2020 11:48:07 +0900
Subject: [PATCH] Insert precondition checker

---
 .../org/apache/druid/segment/loading/DataSegmentPusher.java  | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/core/src/main/java/org/apache/druid/segment/loading/DataSegmentPusher.java b/core/src/main/java/org/apache/druid/segment/loading/DataSegmentPusher.java
index 98c75505c05f..65c46713cd8d 100644
--- a/core/src/main/java/org/apache/druid/segment/loading/DataSegmentPusher.java
+++ b/core/src/main/java/org/apache/druid/segment/loading/DataSegmentPusher.java
@@ -125,6 +125,11 @@ static String getDefaultStorageDir(DataSegment segment, boolean useUniquePath)
 
   static String getDefaultStorageDirWithExistingUniquePath(DataSegment segment, String uniquePath)
   {
+    Preconditions.checkArgument(
+        !(segment.getShardSpec() instanceof BucketNumberedShardSpec),
+        "Illegal shardSpec type[%s]",
+        segment.getShardSpec()
+    );
     return JOINER.join(
         segment.getDataSource(),
         StringUtils.format("%s_%s", segment.getInterval().getStart(), segment.getInterval().getEnd()),