Github user paul-rogers commented on a diff in the pull request:
https://github.com/apache/drill/pull/1058#discussion_r154478390
--- Diff:
exec/java-exec/src/test/java/org/apache/drill/exec/cache/TestBatchSerialization.java
---
@@ -117,11 +117,12 @@ public void testNullableType(MinorType type) throws
IOException {
private void verifySerialize(SingleRowSet rowSet, SingleRowSet expected)
throws IOException {
File dir = OperatorFixture.getTempDir("serial");
- File outFile = new File(dir, "serialze.dat");
- try (OutputStream out = new BufferedOutputStream(new
FileOutputStream(outFile))) {
- VectorSerializer.writer(fixture.allocator(), out)
- .write(rowSet.container(), rowSet.getSv2());
- }
+ VectorSerializer.writer(new SpillSet(dir.getAbsolutePath()),
"serialize.dat")
--- End diff --
The `File dir` line should change to use Tim's new directory watcher
feature.
---
