diff options
Diffstat (limited to 'exec/java-exec/src/test/java/org/apache/drill/exec/store/store/TestAssignment.java')
-rw-r--r-- | exec/java-exec/src/test/java/org/apache/drill/exec/store/store/TestAssignment.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/exec/java-exec/src/test/java/org/apache/drill/exec/store/store/TestAssignment.java b/exec/java-exec/src/test/java/org/apache/drill/exec/store/store/TestAssignment.java index 51e8c1b0a..129796788 100644 --- a/exec/java-exec/src/test/java/org/apache/drill/exec/store/store/TestAssignment.java +++ b/exec/java-exec/src/test/java/org/apache/drill/exec/store/store/TestAssignment.java @@ -26,6 +26,7 @@ import org.apache.drill.exec.store.schedule.AssignmentCreator; import org.apache.drill.exec.store.schedule.CompleteFileWork; import org.apache.drill.exec.store.schedule.EndpointByteMap; import org.apache.drill.exec.store.schedule.EndpointByteMapImpl; +import org.apache.hadoop.fs.Path; import org.junit.Assert; import org.junit.BeforeClass; import org.junit.Test; @@ -125,7 +126,7 @@ public class TestAssignment { private List<CompleteFileWork> generateChunks(int chunks) { List<CompleteFileWork> chunkList = Lists.newArrayList(); for (int i = 0; i < chunks; i++) { - CompleteFileWork chunk = new CompleteFileWork(createByteMap(), 0, FILE_SIZE, "file" + i); + CompleteFileWork chunk = new CompleteFileWork(createByteMap(), 0, FILE_SIZE, new Path("file", Integer.toString(i))); chunkList.add(chunk); } return chunkList; |