[ 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)