diff --git a/extensions-core/azure-extensions/pom.xml b/extensions-core/azure-extensions/pom.xml index 7b321bcd3bc0..11858d9900fc 100644 --- a/extensions-core/azure-extensions/pom.xml +++ b/extensions-core/azure-extensions/pom.xml @@ -185,7 +185,7 @@ LINE COVEREDRATIO - 0.86 + 0.85 BRANCH @@ -200,7 +200,7 @@ METHOD COVEREDRATIO - 0.79 + 0.78 CLASS diff --git a/extensions-core/azure-extensions/src/main/java/org/apache/druid/storage/azure/AzureDataSegmentPusher.java b/extensions-core/azure-extensions/src/main/java/org/apache/druid/storage/azure/AzureDataSegmentPusher.java index 14ea31426cec..461b107b160a 100644 --- a/extensions-core/azure-extensions/src/main/java/org/apache/druid/storage/azure/AzureDataSegmentPusher.java +++ b/extensions-core/azure-extensions/src/main/java/org/apache/druid/storage/azure/AzureDataSegmentPusher.java @@ -153,14 +153,7 @@ public DataSegment push(final File indexFilesDir, final DataSegment segment, fin @Override public Map makeLoadSpec(URI uri) { - return ImmutableMap.of( - "type", - AzureStorageDruidModule.SCHEME, - "containerName", - segmentConfig.getContainer(), - "blobPath", - uri.toString() - ); + return makeLoadSpec(uri.toString()); } @VisibleForTesting @@ -186,7 +179,7 @@ DataSegment uploadDataSegment( final DataSegment outSegment = segment .withSize(size) - .withLoadSpec(this.makeLoadSpec(new URI(azurePath))) + .withLoadSpec(this.makeLoadSpec(azurePath)) .withBinaryVersion(binaryVersion); log.debug("Deleting file [%s]", compressedSegmentData); @@ -194,4 +187,16 @@ DataSegment uploadDataSegment( return outSegment; } + + private Map makeLoadSpec(String prefix) + { + return ImmutableMap.of( + "type", + AzureStorageDruidModule.SCHEME, + "containerName", + segmentConfig.getContainer(), + "blobPath", + prefix + ); + } } diff --git a/extensions-core/azure-extensions/src/test/java/org/apache/druid/storage/azure/AzureDataSegmentPusherTest.java b/extensions-core/azure-extensions/src/test/java/org/apache/druid/storage/azure/AzureDataSegmentPusherTest.java index 3c09f8ed8042..8024d6763ff5 100644 --- a/extensions-core/azure-extensions/src/test/java/org/apache/druid/storage/azure/AzureDataSegmentPusherTest.java +++ b/extensions-core/azure-extensions/src/test/java/org/apache/druid/storage/azure/AzureDataSegmentPusherTest.java @@ -52,9 +52,9 @@ public class AzureDataSegmentPusherTest extends EasyMockSupport private static final String ACCOUNT = "account"; private static final String CONTAINER_NAME = "container"; private static final String PREFIX = "prefix"; - private static final String BLOB_PATH = "test/2015-04-12T00:00:00.000Z_2015-04-13T00:00:00.000Z/1/0/index.zip"; + private static final String BLOB_PATH = " Россия 한국 中国!?/2015-04-12T00:00:00.000Z_2015-04-13T00:00:00.000Z/1/0/index.zip"; private static final DataSegment DATA_SEGMENT = new DataSegment( - "test", + " Россия 한국 中国!?", Intervals.of("2015-04-12/2015-04-13"), "1", ImmutableMap.of("containerName", CONTAINER_NAME, "blobPath", BLOB_PATH),