From c46a39b13e1bfccdc09301b26f9cc4804d417c3b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Xavier=20L=C3=A9aut=C3=A9?= Date: Fri, 4 Apr 2014 14:52:22 -0700 Subject: [PATCH] fix missing arg --- .../java/io/druid/storage/s3/S3DataSegmentArchiver.java | 2 +- .../java/io/druid/storage/s3/S3DataSegmentMoverTest.java | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/s3-extensions/src/main/java/io/druid/storage/s3/S3DataSegmentArchiver.java b/s3-extensions/src/main/java/io/druid/storage/s3/S3DataSegmentArchiver.java index 69b1843c125..e8e98987bf1 100644 --- a/s3-extensions/src/main/java/io/druid/storage/s3/S3DataSegmentArchiver.java +++ b/s3-extensions/src/main/java/io/druid/storage/s3/S3DataSegmentArchiver.java @@ -39,7 +39,7 @@ public class S3DataSegmentArchiver extends S3DataSegmentMover implements DataSeg S3DataSegmentPusherConfig restoreConfig ) { - super(s3Client); + super(s3Client, restoreConfig); this.archiveConfig = archiveConfig; this.restoreConfig = restoreConfig; } diff --git a/s3-extensions/src/test/java/io/druid/storage/s3/S3DataSegmentMoverTest.java b/s3-extensions/src/test/java/io/druid/storage/s3/S3DataSegmentMoverTest.java index 6206da881a4..c13d22de5f1 100644 --- a/s3-extensions/src/test/java/io/druid/storage/s3/S3DataSegmentMoverTest.java +++ b/s3-extensions/src/test/java/io/druid/storage/s3/S3DataSegmentMoverTest.java @@ -62,7 +62,7 @@ public class S3DataSegmentMoverTest public void testMove() throws Exception { MockStorageService mockS3Client = new MockStorageService(); - S3DataSegmentMover mover = new S3DataSegmentMover(mockS3Client); + S3DataSegmentMover mover = new S3DataSegmentMover(mockS3Client, new S3DataSegmentPusherConfig()); mockS3Client.putObject("main", new S3Object("baseKey/test/2013-01-01T00:00:00.000Z_2013-01-02T00:00:00.000Z/1/0/index.zip")); mockS3Client.putObject("main", new S3Object("baseKey/test/2013-01-01T00:00:00.000Z_2013-01-02T00:00:00.000Z/1/0/descriptor.json")); @@ -82,7 +82,7 @@ public class S3DataSegmentMoverTest public void testMoveNoop() throws Exception { MockStorageService mockS3Client = new MockStorageService(); - S3DataSegmentMover mover = new S3DataSegmentMover(mockS3Client); + S3DataSegmentMover mover = new S3DataSegmentMover(mockS3Client, new S3DataSegmentPusherConfig()); mockS3Client.putObject("archive", new S3Object("targetBaseKey/test/2013-01-01T00:00:00.000Z_2013-01-02T00:00:00.000Z/1/0/index.zip")); mockS3Client.putObject("archive", new S3Object("targetBaseKey/test/2013-01-01T00:00:00.000Z_2013-01-02T00:00:00.000Z/1/0/descriptor.json")); @@ -103,7 +103,7 @@ public class S3DataSegmentMoverTest public void testMoveException() throws Exception { MockStorageService mockS3Client = new MockStorageService(); - S3DataSegmentMover mover = new S3DataSegmentMover(mockS3Client); + S3DataSegmentMover mover = new S3DataSegmentMover(mockS3Client, new S3DataSegmentPusherConfig()); mover.move( sourceSegment,