[HOTFIX]s3 lock file fix This closes #2922
Project: http://git-wip-us.apache.org/repos/asf/carbondata/repo Commit: http://git-wip-us.apache.org/repos/asf/carbondata/commit/6df965bc Tree: http://git-wip-us.apache.org/repos/asf/carbondata/tree/6df965bc Diff: http://git-wip-us.apache.org/repos/asf/carbondata/diff/6df965bc Branch: refs/heads/branch-1.5 Commit: 6df965bc21253f6e87b0cd85f12f67a03d8d6d00 Parents: 518e2b6 Author: akashrn5 <akashnilu...@gmail.com> Authored: Wed Nov 14 21:53:39 2018 +0530 Committer: ravipesala <ravi.pes...@gmail.com> Committed: Wed Nov 21 22:43:46 2018 +0530 ---------------------------------------------------------------------- .../carbondata/core/datastore/filesystem/S3CarbonFile.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/carbondata/blob/6df965bc/core/src/main/java/org/apache/carbondata/core/datastore/filesystem/S3CarbonFile.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/carbondata/core/datastore/filesystem/S3CarbonFile.java b/core/src/main/java/org/apache/carbondata/core/datastore/filesystem/S3CarbonFile.java index f1f9fd2..ee67097 100644 --- a/core/src/main/java/org/apache/carbondata/core/datastore/filesystem/S3CarbonFile.java +++ b/core/src/main/java/org/apache/carbondata/core/datastore/filesystem/S3CarbonFile.java @@ -107,8 +107,11 @@ public class S3CarbonFile extends HDFSCarbonFile { // create buffer byte[] byteStreamBuffer = new byte[count]; int bytesRead = dataInputStream.read(byteStreamBuffer); + dataInputStream.close(); stream = fileSystem.create(pt, true, bufferSize); - stream.write(byteStreamBuffer, 0, bytesRead); + if (bytesRead > 0) { + stream.write(byteStreamBuffer, 0, bytesRead); + } } else { stream = fileSystem.create(pt, true, bufferSize); }