JAMES-2623 demonstrate that Cassandra is not able to load big blobs because of excessive //ism
Project: http://git-wip-us.apache.org/repos/asf/james-project/repo Commit: http://git-wip-us.apache.org/repos/asf/james-project/commit/79e46ad5 Tree: http://git-wip-us.apache.org/repos/asf/james-project/tree/79e46ad5 Diff: http://git-wip-us.apache.org/repos/asf/james-project/diff/79e46ad5 Branch: refs/heads/master Commit: 79e46ad51e2d7310097591a30ab0760772c9ff43 Parents: a3de056 Author: Matthieu Baechler <[email protected]> Authored: Mon Dec 10 18:50:36 2018 +0100 Committer: Antoine Duprat <[email protected]> Committed: Thu Dec 20 14:38:43 2018 +0100 ---------------------------------------------------------------------- .../apache/james/blob/cassandra/CassandraBlobsDAOTest.java | 9 +++++++++ 1 file changed, 9 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/james-project/blob/79e46ad5/server/blob/blob-cassandra/src/test/java/org/apache/james/blob/cassandra/CassandraBlobsDAOTest.java ---------------------------------------------------------------------- diff --git a/server/blob/blob-cassandra/src/test/java/org/apache/james/blob/cassandra/CassandraBlobsDAOTest.java b/server/blob/blob-cassandra/src/test/java/org/apache/james/blob/cassandra/CassandraBlobsDAOTest.java index b7d7980..86eeb86 100644 --- a/server/blob/blob-cassandra/src/test/java/org/apache/james/blob/cassandra/CassandraBlobsDAOTest.java +++ b/server/blob/blob-cassandra/src/test/java/org/apache/james/blob/cassandra/CassandraBlobsDAOTest.java @@ -21,6 +21,7 @@ package org.apache.james.blob.cassandra; import static org.assertj.core.api.Assertions.assertThat; +import java.io.InputStream; import java.nio.charset.StandardCharsets; import org.apache.james.backends.cassandra.CassandraCluster; @@ -31,6 +32,7 @@ import org.apache.james.blob.api.BlobStore; import org.apache.james.blob.api.HashBlobId; import org.apache.james.blob.api.MetricableBlobStore; import org.apache.james.blob.api.MetricableBlobStoreContract; +import org.apache.james.util.ZeroedInputStream; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.RegisterExtension; @@ -77,4 +79,11 @@ public class CassandraBlobsDAOTest implements MetricableBlobStoreContract { assertThat(new String(bytes, StandardCharsets.UTF_8)).isEqualTo(longString); } + @Test + void blobStoreShouldSupport100MBBlob() { + BlobId blobId = testee.save(new ZeroedInputStream(100_000_000)).join(); + InputStream bytes = testee.read(blobId); + assertThat(bytes).hasSameContentAs(new ZeroedInputStream(100_000_000)); + } + } \ No newline at end of file --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
