STREAMS-243 | Added "/" char to s3 writer path if it does not already exists
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/ec234251 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/ec234251 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/ec234251 Branch: refs/heads/master Commit: ec2342517f49b88dd585cb6f3a62b4cbbe553dec Parents: 63438d1 Author: Robert Douglas <rdoug...@w2ogroup.com> Authored: Tue Dec 9 09:43:29 2014 -0600 Committer: Robert Douglas <rdoug...@w2ogroup.com> Committed: Tue Dec 9 09:43:29 2014 -0600 ---------------------------------------------------------------------- .../src/main/java/org/apache/streams/s3/S3Configurator.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/ec234251/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3Configurator.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3Configurator.java b/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3Configurator.java index 5130c7a..ccf32c0 100644 --- a/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3Configurator.java +++ b/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3Configurator.java @@ -70,7 +70,7 @@ public class S3Configurator { } if(!s3Configuration.getWriterPath().endsWith("/")) { - s3Configuration.setWriterPath(s3Configuration.getWriterPath()); + s3Configuration.setWriterPath(s3Configuration.getWriterPath() + "/"); } return s3Configuration;
