Uploaded image for project: 'Apache Storm'
  1. Apache Storm
  2. STORM-915 Track and resolve any further random tests failure
  3. STORM-1440

Random test failure on storm-cassandra: AlreadyExistsException: Keyspace weather already exists

    XMLWordPrintableJSON

    Details

    • Type: Sub-task
    • Status: Closed
    • Priority: Major
    • Resolution: Cannot Reproduce
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: storm-cassandra
    • Labels:
      None

      Description

      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, }
      

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              kabhwan Jungtaek Lim
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: