STREAMS-243 | Removed unnecessary precondition failure and replaced with code that rectifies that failure
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/63438d1c Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/63438d1c Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/63438d1c Branch: refs/heads/master Commit: 63438d1c6372120fa4a728c28c821ebe3e555c6b Parents: 8439ff6 Author: Robert Douglas <[email protected]> Authored: Mon Dec 8 18:15:51 2014 -0600 Committer: Robert Douglas <[email protected]> Committed: Mon Dec 8 18:15:51 2014 -0600 ---------------------------------------------------------------------- .../src/main/java/org/apache/streams/s3/S3Configurator.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/63438d1c/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 6bf1672..5130c7a 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 @@ -69,7 +69,9 @@ public class S3Configurator { LOGGER.warn("Could not parse S3Configuration"); } - Preconditions.checkArgument(s3Configuration.getWriterPath().endsWith("/"), s3Configuration.getWriterPath() + " must end with '/'"); + if(!s3Configuration.getWriterPath().endsWith("/")) { + s3Configuration.setWriterPath(s3Configuration.getWriterPath()); + } return s3Configuration; }
