Repository: carbondata Updated Branches: refs/heads/master 39e8e3da5 -> d4e8ba441
[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/d4e8ba44 Tree: http://git-wip-us.apache.org/repos/asf/carbondata/tree/d4e8ba44 Diff: http://git-wip-us.apache.org/repos/asf/carbondata/diff/d4e8ba44 Branch: refs/heads/master Commit: d4e8ba441100bc477c62d04e3b0c63aa8b574ad1 Parents: 39e8e3d Author: akashrn5 <[email protected]> Authored: Wed Nov 14 21:53:39 2018 +0530 Committer: Jacky Li <[email protected]> Committed: Sat Nov 17 15:54:37 2018 +0400 ---------------------------------------------------------------------- .../carbondata/core/datastore/filesystem/S3CarbonFile.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/carbondata/blob/d4e8ba44/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); }
