You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@storm.apache.org by "Jungtaek Lim (JIRA)" <ji...@apache.org> on 2018/02/01 10:29:00 UTC
[jira] [Closed] (STORM-1440) Random test failure on
storm-cassandra: AlreadyExistsException: Keyspace weather already exists
[ https://issues.apache.org/jira/browse/STORM-1440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jungtaek Lim closed STORM-1440.
-------------------------------
Resolution: Cannot Reproduce
Closing as it haven't appear recently. Will reopen once I see this again.
> Random test failure on storm-cassandra: AlreadyExistsException: Keyspace weather already exists
> -----------------------------------------------------------------------------------------------
>
> Key: STORM-1440
> URL: https://issues.apache.org/jira/browse/STORM-1440
> Project: Apache Storm
> Issue Type: Sub-task
> Components: storm-cassandra
> Reporter: Jungtaek Lim
> Priority: Major
>
> {code}
> Running org.apache.storm.cassandra.DynamicStatementBuilderTest
> Tests run: 7, Failures: 0, Errors: 4, Skipped: 0, Time elapsed: 19.203 sec <<< FAILURE! - in org.apache.storm.cassandra.DynamicStatementBuilderTest
> shouldBuildStaticInsertStatementGivenNoKeyspaceAllMapper(org.apache.storm.cassandra.DynamicStatementBuilderTest) Time elapsed: 12.31 sec <<< ERROR!
> com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (tried: /127.0.0.1:9142 (com.datastax.driver.core.OperationTimedOutException: [/127.0.0.1:9142] Operation timed out))
> at com.datastax.driver.core.exceptions.NoHostAvailableException.copy(NoHostAvailableException.java:84)
> at com.datastax.driver.core.DefaultResultSetFuture.extractCauseFromExecutionException(DefaultResultSetFuture.java:269)
> at com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:183)
> at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:52)
> at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:36)
> at org.cassandraunit.CQLDataLoader.initKeyspaceContext(CQLDataLoader.java:62)
> at org.cassandraunit.CQLDataLoader.load(CQLDataLoader.java:31)
> at org.cassandraunit.CassandraCQLUnit.load(CassandraCQLUnit.java:51)
> at org.cassandraunit.BaseCassandraUnit.before(BaseCassandraUnit.java:32)
> at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:46)
> at org.junit.rules.RunRules.evaluate(RunRules.java:20)
> at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
> at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
> at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
> at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
> at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
> at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
> at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
> at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
> at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
> at org.junit.runners.Suite.runChild(Suite.java:127)
> at org.junit.runners.Suite.runChild(Suite.java:26)
> at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
> at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
> at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
> at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
> at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
> at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
> at org.junit.runner.JUnitCore.run(JUnitCore.java:160)
> at org.junit.runner.JUnitCore.run(JUnitCore.java:138)
> at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.createRequestAndRun(JUnitCoreWrapper.java:108)
> at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.executeEager(JUnitCoreWrapper.java:78)
> at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.execute(JUnitCoreWrapper.java:54)
> at org.apache.maven.surefire.junitcore.JUnitCoreProvider.invoke(JUnitCoreProvider.java:144)
> at org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:203)
> at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:155)
> at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:103)
> Caused by: com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (tried: /127.0.0.1:9142 (com.datastax.driver.core.OperationTimedOutException: [/127.0.0.1:9142] Operation timed out))
> at com.datastax.driver.core.RequestHandler.reportNoMoreHosts(RequestHandler.java:216)
> at com.datastax.driver.core.RequestHandler.access$900(RequestHandler.java:45)
> at com.datastax.driver.core.RequestHandler$SpeculativeExecution.sendRequest(RequestHandler.java:276)
> at com.datastax.driver.core.RequestHandler$SpeculativeExecution$1.run(RequestHandler.java:374)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
> at java.lang.Thread.run(Thread.java:745)
> shouldBuildStaticUnloggedBatchStatementGivenNoKeyspaceAndWithFieldsMapper(org.apache.storm.cassandra.DynamicStatementBuilderTest) Time elapsed: 0.001 sec <<< ERROR!
> com.datastax.driver.core.exceptions.AlreadyExistsException: Keyspace weather already exists
> at com.datastax.driver.core.exceptions.AlreadyExistsException.copy(AlreadyExistsException.java:85)
> at com.datastax.driver.core.DefaultResultSetFuture.extractCauseFromExecutionException(DefaultResultSetFuture.java:269)
> at com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:183)
> at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:52)
> at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:36)
> at org.cassandraunit.CQLDataLoader.initKeyspaceContext(CQLDataLoader.java:69)
> at org.cassandraunit.CQLDataLoader.load(CQLDataLoader.java:31)
> at org.cassandraunit.CassandraCQLUnit.load(CassandraCQLUnit.java:51)
> at org.cassandraunit.BaseCassandraUnit.before(BaseCassandraUnit.java:32)
> at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:46)
> at org.junit.rules.RunRules.evaluate(RunRules.java:20)
> at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
> at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
> at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
> at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
> at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
> at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
> at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
> at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
> at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
> at org.junit.runners.Suite.runChild(Suite.java:127)
> at org.junit.runners.Suite.runChild(Suite.java:26)
> at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
> at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
> at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
> at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
> at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
> at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
> at org.junit.runner.JUnitCore.run(JUnitCore.java:160)
> at org.junit.runner.JUnitCore.run(JUnitCore.java:138)
> at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.createRequestAndRun(JUnitCoreWrapper.java:108)
> at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.executeEager(JUnitCoreWrapper.java:78)
> at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.execute(JUnitCoreWrapper.java:54)
> at org.apache.maven.surefire.junitcore.JUnitCoreProvider.invoke(JUnitCoreProvider.java:144)
> at org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:203)
> at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:155)
> at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:103)
> Caused by: com.datastax.driver.core.exceptions.AlreadyExistsException: Keyspace weather already exists
> at com.datastax.driver.core.exceptions.AlreadyExistsException.copy(AlreadyExistsException.java:85)
> at com.datastax.driver.core.Responses$Error.asException(Responses.java:104)
> at com.datastax.driver.core.DefaultResultSetFuture.onSet(DefaultResultSetFuture.java:118)
> at com.datastax.driver.core.RequestHandler.setFinalResult(RequestHandler.java:183)
> at com.datastax.driver.core.RequestHandler.access$2300(RequestHandler.java:45)
> at com.datastax.driver.core.RequestHandler$SpeculativeExecution.setFinalResult(RequestHandler.java:748)
> at com.datastax.driver.core.RequestHandler$SpeculativeExecution.onSet(RequestHandler.java:573)
> at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:991)
> at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:913)
> at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:254)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:242)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:847)
> at io.netty.channel.epoll.EpollSocketChannel$EpollSocketUnsafe.epollInReady(EpollSocketChannel.java:722)
> at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:326)
> at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:264)
> at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111)
> at java.lang.Thread.run(Thread.java:745)
> Caused by: com.datastax.driver.core.exceptions.AlreadyExistsException: Keyspace weather already exists
> at com.datastax.driver.core.Responses$Error$1.decode(Responses.java:69)
> at com.datastax.driver.core.Responses$Error$1.decode(Responses.java:37)
> at com.datastax.driver.core.Message$ProtocolDecoder.decode(Message.java:213)
> at com.datastax.driver.core.Message$ProtocolDecoder.decode(Message.java:204)
> at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:89)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:242)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:847)
> at io.netty.channel.epoll.EpollSocketChannel$EpollSocketUnsafe.epollInReady(EpollSocketChannel.java:722)
> at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:326)
> at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:264)
> at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111)
> at java.lang.Thread.run(Thread.java:745)
> shouldBuildStaticInsertStatementGivenKeyspaceAndAllMapper(org.apache.storm.cassandra.DynamicStatementBuilderTest) Time elapsed: 0.091 sec <<< ERROR!
> com.datastax.driver.core.exceptions.AlreadyExistsException: Keyspace weather already exists
> at com.datastax.driver.core.exceptions.AlreadyExistsException.copy(AlreadyExistsException.java:85)
> at com.datastax.driver.core.DefaultResultSetFuture.extractCauseFromExecutionException(DefaultResultSetFuture.java:269)
> at com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:183)
> at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:52)
> at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:36)
> at org.cassandraunit.CQLDataLoader.initKeyspaceContext(CQLDataLoader.java:69)
> at org.cassandraunit.CQLDataLoader.load(CQLDataLoader.java:31)
> at org.cassandraunit.CassandraCQLUnit.load(CassandraCQLUnit.java:51)
> at org.cassandraunit.BaseCassandraUnit.before(BaseCassandraUnit.java:32)
> at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:46)
> at org.junit.rules.RunRules.evaluate(RunRules.java:20)
> at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
> at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
> at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
> at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
> at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
> at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
> at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
> at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
> at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
> at org.junit.runners.Suite.runChild(Suite.java:127)
> at org.junit.runners.Suite.runChild(Suite.java:26)
> at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
> at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
> at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
> at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
> at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
> at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
> at org.junit.runner.JUnitCore.run(JUnitCore.java:160)
> at org.junit.runner.JUnitCore.run(JUnitCore.java:138)
> at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.createRequestAndRun(JUnitCoreWrapper.java:108)
> at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.executeEager(JUnitCoreWrapper.java:78)
> at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.execute(JUnitCoreWrapper.java:54)
> at org.apache.maven.surefire.junitcore.JUnitCoreProvider.invoke(JUnitCoreProvider.java:144)
> at org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:203)
> at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:155)
> at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:103)
> Caused by: com.datastax.driver.core.exceptions.AlreadyExistsException: Keyspace weather already exists
> at com.datastax.driver.core.exceptions.AlreadyExistsException.copy(AlreadyExistsException.java:85)
> at com.datastax.driver.core.Responses$Error.asException(Responses.java:104)
> at com.datastax.driver.core.DefaultResultSetFuture.onSet(DefaultResultSetFuture.java:118)
> at com.datastax.driver.core.RequestHandler.setFinalResult(RequestHandler.java:183)
> at com.datastax.driver.core.RequestHandler.access$2300(RequestHandler.java:45)
> at com.datastax.driver.core.RequestHandler$SpeculativeExecution.setFinalResult(RequestHandler.java:748)
> at com.datastax.driver.core.RequestHandler$SpeculativeExecution.onSet(RequestHandler.java:573)
> at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:991)
> at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:913)
> at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:254)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:242)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:847)
> at io.netty.channel.epoll.EpollSocketChannel$EpollSocketUnsafe.epollInReady(EpollSocketChannel.java:722)
> at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:326)
> at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:264)
> at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111)
> at java.lang.Thread.run(Thread.java:745)
> Caused by: com.datastax.driver.core.exceptions.AlreadyExistsException: Keyspace weather already exists
> at com.datastax.driver.core.Responses$Error$1.decode(Responses.java:69)
> at com.datastax.driver.core.Responses$Error$1.decode(Responses.java:37)
> at com.datastax.driver.core.Message$ProtocolDecoder.decode(Message.java:213)
> at com.datastax.driver.core.Message$ProtocolDecoder.decode(Message.java:204)
> at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:89)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:242)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:847)
> at io.netty.channel.epoll.EpollSocketChannel$EpollSocketUnsafe.epollInReady(EpollSocketChannel.java:722)
> at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:326)
> at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:264)
> at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111)
> at java.lang.Thread.run(Thread.java:745)
> shouldBuildStaticBoundStatement(org.apache.storm.cassandra.DynamicStatementBuilderTest) Time elapsed: 0.244 sec <<< ERROR!
> com.datastax.driver.core.exceptions.AlreadyExistsException: Keyspace weather already exists
> at com.datastax.driver.core.exceptions.AlreadyExistsException.copy(AlreadyExistsException.java:85)
> at com.datastax.driver.core.DefaultResultSetFuture.extractCauseFromExecutionException(DefaultResultSetFuture.java:269)
> at com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:183)
> at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:52)
> at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:36)
> at org.cassandraunit.CQLDataLoader.initKeyspaceContext(CQLDataLoader.java:69)
> at org.cassandraunit.CQLDataLoader.load(CQLDataLoader.java:31)
> at org.cassandraunit.CassandraCQLUnit.load(CassandraCQLUnit.java:51)
> at org.cassandraunit.BaseCassandraUnit.before(BaseCassandraUnit.java:32)
> at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:46)
> at org.junit.rules.RunRules.evaluate(RunRules.java:20)
> at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
> at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
> at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
> at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
> at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
> at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
> at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
> at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
> at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
> at org.junit.runners.Suite.runChild(Suite.java:127)
> at org.junit.runners.Suite.runChild(Suite.java:26)
> at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
> at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
> at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
> at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
> at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
> at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
> at org.junit.runner.JUnitCore.run(JUnitCore.java:160)
> at org.junit.runner.JUnitCore.run(JUnitCore.java:138)
> at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.createRequestAndRun(JUnitCoreWrapper.java:108)
> at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.executeEager(JUnitCoreWrapper.java:78)
> at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.execute(JUnitCoreWrapper.java:54)
> at org.apache.maven.surefire.junitcore.JUnitCoreProvider.invoke(JUnitCoreProvider.java:144)
> at org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:203)
> at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:155)
> at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:103)
> Caused by: com.datastax.driver.core.exceptions.AlreadyExistsException: Keyspace weather already exists
> at com.datastax.driver.core.exceptions.AlreadyExistsException.copy(AlreadyExistsException.java:85)
> at com.datastax.driver.core.Responses$Error.asException(Responses.java:104)
> at com.datastax.driver.core.DefaultResultSetFuture.onSet(DefaultResultSetFuture.java:118)
> at com.datastax.driver.core.RequestHandler.setFinalResult(RequestHandler.java:183)
> at com.datastax.driver.core.RequestHandler.access$2300(RequestHandler.java:45)
> at com.datastax.driver.core.RequestHandler$SpeculativeExecution.setFinalResult(RequestHandler.java:748)
> at com.datastax.driver.core.RequestHandler$SpeculativeExecution.onSet(RequestHandler.java:573)
> at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:991)
> at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:913)
> at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:254)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:242)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:847)
> at io.netty.channel.epoll.EpollSocketChannel$EpollSocketUnsafe.epollInReady(EpollSocketChannel.java:722)
> at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:326)
> at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:264)
> at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111)
> at java.lang.Thread.run(Thread.java:745)
> Caused by: com.datastax.driver.core.exceptions.AlreadyExistsException: Keyspace weather already exists
> at com.datastax.driver.core.Responses$Error$1.decode(Responses.java:69)
> at com.datastax.driver.core.Responses$Error$1.decode(Responses.java:37)
> at com.datastax.driver.core.Message$ProtocolDecoder.decode(Message.java:213)
> at com.datastax.driver.core.Message$ProtocolDecoder.decode(Message.java:204)
> at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:89)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:242)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:847)
> at io.netty.channel.epoll.EpollSocketChannel$EpollSocketUnsafe.epollInReady(EpollSocketChannel.java:722)
> at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:326)
> at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:264)
> at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111)
> at java.lang.Thread.run(Thread.java:745)
> classname: org.apache.storm.cassandra.DynamicStatementBuilderTest / testname: shouldBuildStaticInsertStatementGivenNoKeyspaceAllMapper
> com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (tried: /127.0.0.1:9142 (com.datastax.driver.core.OperationTimedOutException: [/127.0.0.1:9142] Operation timed out))
> at com.datastax.driver.core.exceptions.NoHostAvailableException.copy(NoHostAvailableException.java:84)
> at com.datastax.driver.core.DefaultResultSetFuture.extractCauseFromExecutionException(DefaultResultSetFuture.java:269)
> at com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:183)
> at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:52)
> at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:36)
> at org.cassandraunit.CQLDataLoader.initKeyspaceContext(CQLDataLoader.java:62)
> at org.cassandraunit.CQLDataLoader.load(CQLDataLoader.java:31)
> at org.cassandraunit.CassandraCQLUnit.load(CassandraCQLUnit.java:51)
> at org.cassandraunit.BaseCassandraUnit.before(BaseCassandraUnit.java:32)
> at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:46)
> at org.junit.rules.RunRules.evaluate(RunRules.java:20)
> at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
> at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
> at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
> at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
> at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
> at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
> at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
> at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
> at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
> at org.junit.runners.Suite.runChild(Suite.java:127)
> at org.junit.runners.Suite.runChild(Suite.java:26)
> at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
> at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
> at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
> at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
> at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
> at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
> at org.junit.runner.JUnitCore.run(JUnitCore.java:160)
> at org.junit.runner.JUnitCore.run(JUnitCore.java:138)
> at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.createRequestAndRun(JUnitCoreWrapper.java:108)
> at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.executeEager(JUnitCoreWrapper.java:78)
> at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.execute(JUnitCoreWrapper.java:54)
> at org.apache.maven.surefire.junitcore.JUnitCoreProvider.invoke(JUnitCoreProvider.java:144)
> at org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:203)
> at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:155)
> at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:103)
> Caused by: com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (tried: /127.0.0.1:9142 (com.datastax.driver.core.OperationTimedOutException: [/127.0.0.1:9142] Operation timed out))
> at com.datastax.driver.core.RequestHandler.reportNoMoreHosts(RequestHandler.java:216)
> at com.datastax.driver.core.RequestHandler.access$900(RequestHandler.java:45)
> at com.datastax.driver.core.RequestHandler$SpeculativeExecution.sendRequest(RequestHandler.java:276)
> at com.datastax.driver.core.RequestHandler$SpeculativeExecution$1.run(RequestHandler.java:374)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
> at java.lang.Thread.run(Thread.java:745)
> -------------------- system-out --------------------
> 6736 [main] INFO c.d.d.c.p.DCAwareRoundRobinPolicy - Using data-center name 'datacenter1' for DCAwareRoundRobinPolicy (if this is incorrect, please provide the correct datacenter name with DCAwareRoundRobinPolicy constructor)
> 6736 [main] INFO c.d.d.c.Cluster - New Cassandra host /127.0.0.1:9142 added
> 6756 [SharedPool-Worker-2] INFO o.a.c.s.MigrationManager - Drop Keyspace 'weather'
> 6760 [MigrationStage:1] INFO o.a.c.d.ColumnFamilyStore - Enqueuing flush of schema_keyspaces: 155 (0%) on-heap, 0 (0%) off-heap
> 6760 [MemtableFlushWriter:2] INFO o.a.c.d.Memtable - Writing Memtable-schema_keyspaces@1570950213(0 serialized bytes, 1 ops, 0%/0% of on/off-heap limit)
> --------------------------------------------------
> --------------------------------------------------
> classname: org.apache.storm.cassandra.DynamicStatementBuilderTest / testname: shouldBuildStaticUnloggedBatchStatementGivenNoKeyspaceAndWithFieldsMapper
> com.datastax.driver.core.exceptions.AlreadyExistsException: Keyspace weather already exists
> at com.datastax.driver.core.exceptions.AlreadyExistsException.copy(AlreadyExistsException.java:85)
> at com.datastax.driver.core.DefaultResultSetFuture.extractCauseFromExecutionException(DefaultResultSetFuture.java:269)
> at com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:183)
> at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:52)
> at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:36)
> at org.cassandraunit.CQLDataLoader.initKeyspaceContext(CQLDataLoader.java:69)
> at org.cassandraunit.CQLDataLoader.load(CQLDataLoader.java:31)
> at org.cassandraunit.CassandraCQLUnit.load(CassandraCQLUnit.java:51)
> at org.cassandraunit.BaseCassandraUnit.before(BaseCassandraUnit.java:32)
> at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:46)
> at org.junit.rules.RunRules.evaluate(RunRules.java:20)
> at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
> at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
> at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
> at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
> at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
> at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
> at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
> at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
> at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
> at org.junit.runners.Suite.runChild(Suite.java:127)
> at org.junit.runners.Suite.runChild(Suite.java:26)
> at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
> at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
> at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
> at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
> at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
> at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
> at org.junit.runner.JUnitCore.run(JUnitCore.java:160)
> at org.junit.runner.JUnitCore.run(JUnitCore.java:138)
> at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.createRequestAndRun(JUnitCoreWrapper.java:108)
> at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.executeEager(JUnitCoreWrapper.java:78)
> at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.execute(JUnitCoreWrapper.java:54)
> at org.apache.maven.surefire.junitcore.JUnitCoreProvider.invoke(JUnitCoreProvider.java:144)
> at org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:203)
> at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:155)
> at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:103)
> Caused by: com.datastax.driver.core.exceptions.AlreadyExistsException: Keyspace weather already exists
> at com.datastax.driver.core.exceptions.AlreadyExistsException.copy(AlreadyExistsException.java:85)
> at com.datastax.driver.core.Responses$Error.asException(Responses.java:104)
> at com.datastax.driver.core.DefaultResultSetFuture.onSet(DefaultResultSetFuture.java:118)
> at com.datastax.driver.core.RequestHandler.setFinalResult(RequestHandler.java:183)
> at com.datastax.driver.core.RequestHandler.access$2300(RequestHandler.java:45)
> at com.datastax.driver.core.RequestHandler$SpeculativeExecution.setFinalResult(RequestHandler.java:748)
> at com.datastax.driver.core.RequestHandler$SpeculativeExecution.onSet(RequestHandler.java:573)
> at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:991)
> at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:913)
> at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:254)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:242)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:847)
> at io.netty.channel.epoll.EpollSocketChannel$EpollSocketUnsafe.epollInReady(EpollSocketChannel.java:722)
> at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:326)
> at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:264)
> at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111)
> at java.lang.Thread.run(Thread.java:745)
> Caused by: com.datastax.driver.core.exceptions.AlreadyExistsException: Keyspace weather already exists
> at com.datastax.driver.core.Responses$Error$1.decode(Responses.java:69)
> at com.datastax.driver.core.Responses$Error$1.decode(Responses.java:37)
> at com.datastax.driver.core.Message$ProtocolDecoder.decode(Message.java:213)
> at com.datastax.driver.core.Message$ProtocolDecoder.decode(Message.java:204)
> at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:89)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:242)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:847)
> at io.netty.channel.epoll.EpollSocketChannel$EpollSocketUnsafe.epollInReady(EpollSocketChannel.java:722)
> at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:326)
> at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:264)
> at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111)
> at java.lang.Thread.run(Thread.java:745)
> -------------------- system-out --------------------
> 18858 [main] INFO c.d.d.c.p.DCAwareRoundRobinPolicy - Using data-center name 'datacenter1' for DCAwareRoundRobinPolicy (if this is incorrect, please provide the correct datacenter name with DCAwareRoundRobinPolicy constructor)
> 18858 [main] INFO c.d.d.c.Cluster - New Cassandra host /127.0.0.1:9142 added
> --------------------------------------------------
> --------------------------------------------------
> classname: org.apache.storm.cassandra.DynamicStatementBuilderTest / testname: shouldBuildStaticInsertStatementGivenKeyspaceAndAllMapper
> com.datastax.driver.core.exceptions.AlreadyExistsException: Keyspace weather already exists
> at com.datastax.driver.core.exceptions.AlreadyExistsException.copy(AlreadyExistsException.java:85)
> at com.datastax.driver.core.DefaultResultSetFuture.extractCauseFromExecutionException(DefaultResultSetFuture.java:269)
> at com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:183)
> at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:52)
> at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:36)
> at org.cassandraunit.CQLDataLoader.initKeyspaceContext(CQLDataLoader.java:69)
> at org.cassandraunit.CQLDataLoader.load(CQLDataLoader.java:31)
> at org.cassandraunit.CassandraCQLUnit.load(CassandraCQLUnit.java:51)
> at org.cassandraunit.BaseCassandraUnit.before(BaseCassandraUnit.java:32)
> at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:46)
> at org.junit.rules.RunRules.evaluate(RunRules.java:20)
> at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
> at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
> at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
> at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
> at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
> at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
> at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
> at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
> at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
> at org.junit.runners.Suite.runChild(Suite.java:127)
> at org.junit.runners.Suite.runChild(Suite.java:26)
> at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
> at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
> at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
> at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
> at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
> at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
> at org.junit.runner.JUnitCore.run(JUnitCore.java:160)
> at org.junit.runner.JUnitCore.run(JUnitCore.java:138)
> at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.createRequestAndRun(JUnitCoreWrapper.java:108)
> at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.executeEager(JUnitCoreWrapper.java:78)
> at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.execute(JUnitCoreWrapper.java:54)
> at org.apache.maven.surefire.junitcore.JUnitCoreProvider.invoke(JUnitCoreProvider.java:144)
> at org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:203)
> at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:155)
> at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:103)
> Caused by: com.datastax.driver.core.exceptions.AlreadyExistsException: Keyspace weather already exists
> at com.datastax.driver.core.exceptions.AlreadyExistsException.copy(AlreadyExistsException.java:85)
> at com.datastax.driver.core.Responses$Error.asException(Responses.java:104)
> at com.datastax.driver.core.DefaultResultSetFuture.onSet(DefaultResultSetFuture.java:118)
> at com.datastax.driver.core.RequestHandler.setFinalResult(RequestHandler.java:183)
> at com.datastax.driver.core.RequestHandler.access$2300(RequestHandler.java:45)
> at com.datastax.driver.core.RequestHandler$SpeculativeExecution.setFinalResult(RequestHandler.java:748)
> at com.datastax.driver.core.RequestHandler$SpeculativeExecution.onSet(RequestHandler.java:573)
> at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:991)
> at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:913)
> at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:254)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:242)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:847)
> at io.netty.channel.epoll.EpollSocketChannel$EpollSocketUnsafe.epollInReady(EpollSocketChannel.java:722)
> at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:326)
> at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:264)
> at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111)
> at java.lang.Thread.run(Thread.java:745)
> Caused by: com.datastax.driver.core.exceptions.AlreadyExistsException: Keyspace weather already exists
> at com.datastax.driver.core.Responses$Error$1.decode(Responses.java:69)
> at com.datastax.driver.core.Responses$Error$1.decode(Responses.java:37)
> at com.datastax.driver.core.Message$ProtocolDecoder.decode(Message.java:213)
> at com.datastax.driver.core.Message$ProtocolDecoder.decode(Message.java:204)
> at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:89)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:242)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:847)
> at io.netty.channel.epoll.EpollSocketChannel$EpollSocketUnsafe.epollInReady(EpollSocketChannel.java:722)
> at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:326)
> at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:264)
> at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111)
> at java.lang.Thread.run(Thread.java:745)
> -------------------- system-out --------------------
> 18976 [MemtableFlushWriter:2] INFO o.a.c.d.Memtable - Completed flushing /home/travis/build/apache/storm/external/storm-cassandra/target/embeddedCassandra/data/system/schema_keyspaces-b0f2235744583cdb9631c43e59ce3676/system-schema_keyspaces-ka-11-Data.db (33 bytes) for commitlog position ReplayPosition(segmentId=1451364264392, position=9114)
> 18979 [main] INFO c.d.d.c.p.DCAwareRoundRobinPolicy - Using data-center name 'datacenter1' for DCAwareRoundRobinPolicy (if this is incorrect, please provide the correct datacenter name with DCAwareRoundRobinPolicy constructor)
> 18980 [main] INFO c.d.d.c.Cluster - New Cassandra host /127.0.0.1:9142 added
> --------------------------------------------------
> --------------------------------------------------
> classname: org.apache.storm.cassandra.DynamicStatementBuilderTest / testname: shouldBuildStaticBoundStatement
> com.datastax.driver.core.exceptions.AlreadyExistsException: Keyspace weather already exists
> at com.datastax.driver.core.exceptions.AlreadyExistsException.copy(AlreadyExistsException.java:85)
> at com.datastax.driver.core.DefaultResultSetFuture.extractCauseFromExecutionException(DefaultResultSetFuture.java:269)
> at com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:183)
> at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:52)
> at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:36)
> at org.cassandraunit.CQLDataLoader.initKeyspaceContext(CQLDataLoader.java:69)
> at org.cassandraunit.CQLDataLoader.load(CQLDataLoader.java:31)
> at org.cassandraunit.CassandraCQLUnit.load(CassandraCQLUnit.java:51)
> at org.cassandraunit.BaseCassandraUnit.before(BaseCassandraUnit.java:32)
> at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:46)
> at org.junit.rules.RunRules.evaluate(RunRules.java:20)
> at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
> at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
> at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
> at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
> at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
> at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
> at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
> at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
> at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
> at org.junit.runners.Suite.runChild(Suite.java:127)
> at org.junit.runners.Suite.runChild(Suite.java:26)
> at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
> at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
> at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
> at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
> at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
> at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
> at org.junit.runner.JUnitCore.run(JUnitCore.java:160)
> at org.junit.runner.JUnitCore.run(JUnitCore.java:138)
> at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.createRequestAndRun(JUnitCoreWrapper.java:108)
> at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.executeEager(JUnitCoreWrapper.java:78)
> at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.execute(JUnitCoreWrapper.java:54)
> at org.apache.maven.surefire.junitcore.JUnitCoreProvider.invoke(JUnitCoreProvider.java:144)
> at org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:203)
> at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:155)
> at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:103)
> Caused by: com.datastax.driver.core.exceptions.AlreadyExistsException: Keyspace weather already exists
> at com.datastax.driver.core.exceptions.AlreadyExistsException.copy(AlreadyExistsException.java:85)
> at com.datastax.driver.core.Responses$Error.asException(Responses.java:104)
> at com.datastax.driver.core.DefaultResultSetFuture.onSet(DefaultResultSetFuture.java:118)
> at com.datastax.driver.core.RequestHandler.setFinalResult(RequestHandler.java:183)
> at com.datastax.driver.core.RequestHandler.access$2300(RequestHandler.java:45)
> at com.datastax.driver.core.RequestHandler$SpeculativeExecution.setFinalResult(RequestHandler.java:748)
> at com.datastax.driver.core.RequestHandler$SpeculativeExecution.onSet(RequestHandler.java:573)
> at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:991)
> at com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:913)
> at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:254)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:242)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:847)
> at io.netty.channel.epoll.EpollSocketChannel$EpollSocketUnsafe.epollInReady(EpollSocketChannel.java:722)
> at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:326)
> at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:264)
> at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111)
> at java.lang.Thread.run(Thread.java:745)
> Caused by: com.datastax.driver.core.exceptions.AlreadyExistsException: Keyspace weather already exists
> at com.datastax.driver.core.Responses$Error$1.decode(Responses.java:69)
> at com.datastax.driver.core.Responses$Error$1.decode(Responses.java:37)
> at com.datastax.driver.core.Message$ProtocolDecoder.decode(Message.java:213)
> at com.datastax.driver.core.Message$ProtocolDecoder.decode(Message.java:204)
> at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:89)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:242)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:847)
> at io.netty.channel.epoll.EpollSocketChannel$EpollSocketUnsafe.epollInReady(EpollSocketChannel.java:722)
> at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:326)
> at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:264)
> at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111)
> at java.lang.Thread.run(Thread.java:745)
> -------------------- system-out --------------------
> 19062 [MigrationStage:1] INFO o.a.c.d.ColumnFamilyStore - Enqueuing flush of schema_columnfamilies: 155 (0%) on-heap, 0 (0%) off-heap
> 19063 [MemtableFlushWriter:1] INFO o.a.c.d.Memtable - Writing Memtable-schema_columnfamilies@614174029(0 serialized bytes, 1 ops, 0%/0% of on/off-heap limit)
> 19103 [MemtableFlushWriter:1] INFO o.a.c.d.Memtable - Completed flushing /home/travis/build/apache/storm/external/storm-cassandra/target/embeddedCassandra/data/system/schema_columnfamilies-45f5b36024bc3f83a3631034ea4fa697/system-schema_columnfamilies-ka-8-Data.db (33 bytes) for commitlog position ReplayPosition(segmentId=1451364264392, position=9122)
> 19104 [CompactionExecutor:2] INFO o.a.c.d.c.CompactionTask - Compacting [SSTableReader(path='/home/travis/build/apache/storm/external/storm-cassandra/target/embeddedCassandra/data/system/schema_columnfamilies-45f5b36024bc3f83a3631034ea4fa697/system-schema_columnfamilies-ka-6-Data.db'), SSTableReader(path='/home/travis/build/apache/storm/external/storm-cassandra/target/embeddedCassandra/data/system/schema_columnfamilies-45f5b36024bc3f83a3631034ea4fa697/system-schema_columnfamilies-ka-5-Data.db'), SSTableReader(path='/home/travis/build/apache/storm/external/storm-cassandra/target/embeddedCassandra/data/system/schema_columnfamilies-45f5b36024bc3f83a3631034ea4fa697/system-schema_columnfamilies-ka-7-Data.db'), SSTableReader(path='/home/travis/build/apache/storm/external/storm-cassandra/target/embeddedCassandra/data/system/schema_columnfamilies-45f5b36024bc3f83a3631034ea4fa697/system-schema_columnfamilies-ka-8-Data.db')]
> 19108 [MigrationStage:1] INFO o.a.c.d.ColumnFamilyStore - Enqueuing flush of schema_columns: 155 (0%) on-heap, 0 (0%) off-heap
> 19108 [MemtableFlushWriter:2] INFO o.a.c.d.Memtable - Writing Memtable-schema_columns@1627156840(0 serialized bytes, 1 ops, 0%/0% of on/off-heap limit)
> 19131 [main] INFO c.d.d.c.p.DCAwareRoundRobinPolicy - Using data-center name 'datacenter1' for DCAwareRoundRobinPolicy (if this is incorrect, please provide the correct datacenter name with DCAwareRoundRobinPolicy constructor)
> 19131 [main] INFO c.d.d.c.Cluster - New Cassandra host /127.0.0.1:9142 added
> 19152 [MemtableFlushWriter:2] INFO o.a.c.d.Memtable - Completed flushing /home/travis/build/apache/storm/external/storm-cassandra/target/embeddedCassandra/data/system/schema_columns-296e9c049bec3085827dc17d3df2122a/system-schema_columns-ka-8-Data.db (33 bytes) for commitlog position ReplayPosition(segmentId=1451364264392, position=9122)
> 19153 [CompactionExecutor:1] INFO o.a.c.d.c.CompactionTask - Compacting [SSTableReader(path='/home/travis/build/apache/storm/external/storm-cassandra/target/embeddedCassandra/data/system/schema_columns-296e9c049bec3085827dc17d3df2122a/system-schema_columns-ka-6-Data.db'), SSTableReader(path='/home/travis/build/apache/storm/external/storm-cassandra/target/embeddedCassandra/data/system/schema_columns-296e9c049bec3085827dc17d3df2122a/system-schema_columns-ka-5-Data.db'), SSTableReader(path='/home/travis/build/apache/storm/external/storm-cassandra/target/embeddedCassandra/data/system/schema_columns-296e9c049bec3085827dc17d3df2122a/system-schema_columns-ka-7-Data.db'), SSTableReader(path='/home/travis/build/apache/storm/external/storm-cassandra/target/embeddedCassandra/data/system/schema_columns-296e9c049bec3085827dc17d3df2122a/system-schema_columns-ka-8-Data.db')]
> 19163 [MigrationStage:1] INFO o.a.c.d.ColumnFamilyStore - Enqueuing flush of schema_triggers: 155 (0%) on-heap, 0 (0%) off-heap
> 19163 [MemtableFlushWriter:1] INFO o.a.c.d.Memtable - Writing Memtable-schema_triggers@1163581484(0 serialized bytes, 1 ops, 0%/0% of on/off-heap limit)
> 19189 [MemtableFlushWriter:1] INFO o.a.c.d.Memtable - Completed flushing /home/travis/build/apache/storm/external/storm-cassandra/target/embeddedCassandra/data/system/schema_triggers-0359bc7171233ee19a4ab9dfb11fc125/system-schema_triggers-ka-3-Data.db (33 bytes) for commitlog position ReplayPosition(segmentId=1451364264392, position=9122)
> 19192 [CompactionExecutor:2] INFO o.a.c.d.c.CompactionTask - Compacted 4 sstables to [target/embeddedCassandra/data/system/schema_columnfamilies-45f5b36024bc3f83a3631034ea4fa697/system-schema_columnfamilies-ka-9,]. 8,698 bytes to 6,907 (~79% of original) in 86ms = 0.076593MB/s. 6 total partitions merged to 3. Partition merge counts were {1:2, 4:1, }
> 19196 [MigrationStage:1] INFO o.a.c.d.ColumnFamilyStore - Enqueuing flush of schema_usertypes: 155 (0%) on-heap, 0 (0%) off-heap
> 19196 [MemtableFlushWriter:2] INFO o.a.c.d.Memtable - Writing Memtable-schema_usertypes@53100229(0 serialized bytes, 1 ops, 0%/0% of on/off-heap limit)
> 19201 [MemtableFlushWriter:2] INFO o.a.c.d.Memtable - Completed flushing /home/travis/build/apache/storm/external/storm-cassandra/target/embeddedCassandra/data/system/schema_usertypes-3aa752254f82350b8d5c430fa221fa0a/system-schema_usertypes-ka-3-Data.db (33 bytes) for commitlog position ReplayPosition(segmentId=1451364264392, position=9607)
> 19205 [MigrationStage:1] INFO o.a.c.d.ColumnFamilyStore - Enqueuing flush of local: 881 (0%) on-heap, 0 (0%) off-heap
> 19206 [MemtableFlushWriter:1] INFO o.a.c.d.Memtable - Writing Memtable-local@77342413(126 serialized bytes, 9 ops, 0%/0% of on/off-heap limit)
> 19212 [MemtableFlushWriter:1] INFO o.a.c.d.Memtable - Completed flushing /home/travis/build/apache/storm/external/storm-cassandra/target/embeddedCassandra/data/system/local-7ad54392bcdd35a684174e047860b377/system-local-ka-8-Data.db (133 bytes) for commitlog position ReplayPosition(segmentId=1451364264392, position=9720)
> 19213 [CompactionExecutor:2] INFO o.a.c.d.c.CompactionTask - Compacting [SSTableReader(path='/home/travis/build/apache/storm/external/storm-cassandra/target/embeddedCassandra/data/system/local-7ad54392bcdd35a684174e047860b377/system-local-ka-8-Data.db'), SSTableReader(path='/home/travis/build/apache/storm/external/storm-cassandra/target/embeddedCassandra/data/system/local-7ad54392bcdd35a684174e047860b377/system-local-ka-6-Data.db'), SSTableReader(path='/home/travis/build/apache/storm/external/storm-cassandra/target/embeddedCassandra/data/system/local-7ad54392bcdd35a684174e047860b377/system-local-ka-7-Data.db'), SSTableReader(path='/home/travis/build/apache/storm/external/storm-cassandra/target/embeddedCassandra/data/system/local-7ad54392bcdd35a684174e047860b377/system-local-ka-5-Data.db')]
> 19217 [MigrationStage:1] INFO o.a.c.c.QueryProcessor - Table weather.station was dropped, invalidating related prepared statements
> 19228 [cluster6-nio-worker-0] WARN c.d.d.c.Cluster - Received a DROPPED notification for table weather.station, but this keyspace is unknown in our metadata
> 19229 [cluster5-nio-worker-0] WARN c.d.d.c.Cluster - Received a DROPPED notification for table weather.station, but this keyspace is unknown in our metadata
> 19229 [cluster4-nio-worker-0] WARN c.d.d.c.Cluster - Received a DROPPED notification for table weather.station, but this keyspace is unknown in our metadata
> 19233 [MigrationStage:1] INFO o.a.c.d.ColumnFamilyStore - Enqueuing flush of IndexInfo: 155 (0%) on-heap, 0 (0%) off-heap
> 19233 [MigrationStage:1] INFO o.a.c.d.ColumnFamilyStore - Enqueuing flush of compaction_history: 5552 (0%) on-heap, 0 (0%) off-heap
> 19234 [MemtableFlushWriter:2] INFO o.a.c.d.Memtable - Writing Memtable-IndexInfo@1218571140(0 serialized bytes, 1 ops, 0%/0% of on/off-heap limit)
> 19235 [MemtableFlushWriter:1] INFO o.a.c.d.Memtable - Writing Memtable-compaction_history@2121092188(1124 serialized bytes, 40 ops, 0%/0% of on/off-heap limit)
> 19238 [MemtableFlushWriter:2] INFO o.a.c.d.Memtable - Completed flushing /home/travis/build/apache/storm/external/storm-cassandra/target/embeddedCassandra/data/system/IndexInfo-9f5c6374d48532299a0a5094af9ad1e3/system-IndexInfo-ka-2-Data.db (33 bytes) for commitlog position ReplayPosition(segmentId=1451364264393, position=24)
> 19267 [MemtableFlushWriter:1] INFO o.a.c.d.Memtable - Completed flushing /home/travis/build/apache/storm/external/storm-cassandra/target/embeddedCassandra/data/system/compaction_history-b4dbb7b4dc493fb5b3bfce6e434832ca/system-compaction_history-ka-2-Data.db (547 bytes) for commitlog position ReplayPosition(segmentId=1451364264393, position=24)
> 19270 [MigrationStage:1] INFO o.a.c.d.ColumnFamilyStore - Enqueuing flush of local: 357 (0%) on-heap, 0 (0%) off-heap
> 19270 [MemtableFlushWriter:2] INFO o.a.c.d.Memtable - Writing Memtable-local@1386225500(40 serialized bytes, 1 ops, 0%/0% of on/off-heap limit)
> 19279 [MemtableFlushWriter:2] INFO o.a.c.d.Memtable - Completed flushing /home/travis/build/apache/storm/external/storm-cassandra/target/embeddedCassandra/data/system/local-7ad54392bcdd35a684174e047860b377/system-local-ka-10-Data.db (80 bytes) for commitlog position ReplayPosition(segmentId=1451364264393, position=137)
> 19279 [MigrationStage:1] INFO o.a.c.c.QueryProcessor - Table weather.temperature was dropped, invalidating related prepared statements
> 19280 [CompactionExecutor:2] INFO o.a.c.d.c.CompactionTask - Compacted 4 sstables to [target/embeddedCassandra/data/system/local-7ad54392bcdd35a684174e047860b377/system-local-ka-9,]. 873 bytes to 545 (~62% of original) in 58ms = 0.008961MB/s. 4 total partitions merged to 1. Partition merge counts were {4:1, }
> {code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)