at rx.internal.util.ScalarSynchronousObservable$1.call(ScalarSynchronousObservable.java:35) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable.unsafeSubscribe(Observable.java:7710) at rx.internal.operators.OperatorSubscribeOn$1$1.call(OperatorSubscribeOn.java:62) at rx.schedulers.ImmediateScheduler$InnerImmediateScheduler.schedule(ImmediateScheduler.java:58) at rx.internal.operators.OperatorSubscribeOn$1.onNext(OperatorSubscribeOn.java:57) at rx.internal.operators.OperatorSubscribeOn$1.onNext(OperatorSubscribeOn.java:43) at rx.internal.util.ScalarSynchronousObservable$1.call(ScalarSynchronousObservable.java:46) at rx.internal.util.ScalarSynchronousObservable$1.call(ScalarSynchronousObservable.java:35) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable.unsafeSubscribe(Observable.java:7710) at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:231) at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:140) at rx.internal.operators.OperatorMap$1.onNext(OperatorMap.java:55) at rx.internal.operators.OperatorBufferWithSize$1.onNext(OperatorBufferWithSize.java:103) at rx.internal.operators.OnSubscribeFromIterable$IterableProducer.slowpath(OnSubscribeFromIterable.java:97) at rx.internal.operators.OnSubscribeFromIterable$IterableProducer.request(OnSubscribeFromIterable.java:73) at rx.internal.operators.OperatorBufferWithSize$1$1.request(OperatorBufferWithSize.java:88) at rx.Subscriber.setProducer(Subscriber.java:211) at rx.Subscriber.setProducer(Subscriber.java:205) at rx.internal.operators.OperatorBufferWithSize$1.setProducer(OperatorBufferWithSize.java:74) at rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:49) at rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:32) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable.subscribe(Observable.java:7804) at rx.Observable.subscribe(Observable.java:7772) at rx.observables.BlockingObservable.blockForSingle(BlockingObservable.java:432) at rx.observables.BlockingObservable.last(BlockingObservable.java:219) at org.apache.usergrid.persistence.collection.serialization.impl.MvccEntitySerializationStrategyImpl.load(MvccEntitySerializationStrategyImpl. java:223) at org.apache.usergrid.persistence.collection.serialization.impl.MvccEntitySerializationStrategyProxyImpl.load(MvccEntitySerializationStrategy ProxyImpl.java:92) at org.apache.usergrid.persistence.collection.impl.EntityCollectionManagerImpl$1.call(EntityCollectionManagerImpl.java:246) at org.apache.usergrid.persistence.collection.impl.EntityCollectionManagerImpl$1.call(EntityCollectionManagerImpl.java:240) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable.subscribe(Observable.java:7804) at rx.Observable.subscribe(Observable.java:7772) at rx.observables.BlockingObservable.blockForSingle(BlockingObservable.java:432) at rx.observables.BlockingObservable.lastOrDefault(BlockingObservable.java:252) at org.apache.usergrid.corepersistence.CpEntityManager.load(CpEntityManager.java:325) at org.apache.usergrid.corepersistence.CpEntityManager.getEntity(CpEntityManager.java:514) at org.apache.usergrid.corepersistence.CpEntityManager.get(CpEntityManager.java:481) at org.apache.usergrid.corepersistence.CpEntityManager.getApplication(CpEntityManager.java:737) at org.apache.usergrid.services.ServiceManager.init(ServiceManager.java:101) ... 9 more Caused by: com.netflix.astyanax.connectionpool.exceptions.BadRequestException: BadRequestException: [host=127.0.0.1(127.0.0.1):9160, latency=1(4), att empts=1]InvalidRequestException(why:Keyspace Usergrid_Applications does not exist) at com.netflix.astyanax.thrift.ThriftConverter.ToConnectionPoolException(ThriftConverter.java:159) at com.netflix.astyanax.thrift.ThriftSyncConnectionFactoryImpl$ThriftConnection.execute(ThriftSyncConnectionFactoryImpl.java:137) at com.netflix.astyanax.connectionpool.impl.AbstractExecuteWithFailoverImpl.tryOperation(AbstractExecuteWithFailoverImpl.java:119) at com.netflix.astyanax.connectionpool.impl.AbstractHostPartitionConnectionPool.executeWithFailover(AbstractHostPartitionConnectionPool.java:3 38) at com.netflix.astyanax.thrift.ThriftColumnFamilyQueryImpl$4.execute(ThriftColumnFamilyQueryImpl.java:532) at org.apache.usergrid.persistence.collection.serialization.impl.MvccEntitySerializationStrategyImpl.lambda$null$24(MvccEntitySerializationStr ategyImpl.java:189) ... 86 more Caused by: InvalidRequestException(why:Keyspace Usergrid_Applications does not exist) at org.apache.cassandra.thrift.Cassandra$set_keyspace_result.read(Cassandra.java:5540) at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78) at org.apache.cassandra.thrift.Cassandra$Client.recv_set_keyspace(Cassandra.java:540) at org.apache.cassandra.thrift.Cassandra$Client.set_keyspace(Cassandra.java:527) at com.netflix.astyanax.thrift.ThriftSyncConnectionFactoryImpl$ThriftConnection.execute(ThriftSyncConnectionFactoryImpl.java:125) ... 90 more Caused by: rx.exceptions.OnErrorThrowable$OnNextValue: OnError while emitting onNext value: java.util.ArrayList.class at rx.exceptions.OnErrorThrowable.addValueAsLastCause(OnErrorThrowable.java:104) at rx.internal.operators.OperatorMap$1.onNext(OperatorMap.java:58) ... 84 more 2015-10-30 18:03:05 ERROR services.notifications.QueueListener.run(123)- failed to start push java.lang.RuntimeException: org.apache.usergrid.persistence.collection.exception.CollectionRuntimeException: An error occurred connecting to cassandra at org.apache.usergrid.services.ServiceManager.init(ServiceManager.java:111) at org.apache.usergrid.services.ServiceManagerFactory.getServiceManager(ServiceManagerFactory.java:69) at org.apache.usergrid.services.notifications.QueueListener.execute(QueueListener.java:145) at org.apache.usergrid.services.notifications.QueueListener.access$000(QueueListener.java:47) at org.apache.usergrid.services.notifications.QueueListener$1.run(QueueListener.java:121) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745) Caused by: org.apache.usergrid.persistence.collection.exception.CollectionRuntimeException: An error occurred connecting to cassandra at org.apache.usergrid.persistence.collection.serialization.impl.MvccEntitySerializationStrategyImpl.lambda$null$24(MvccEntitySerializationStr ategyImpl.java:192) at org.apache.usergrid.persistence.collection.serialization.impl.MvccEntitySerializationStrategyImpl$$Lambda$16/1171381486.call(Unknown Source ) at rx.internal.operators.OperatorMap$1.onNext(OperatorMap.java:55) at rx.internal.util.ScalarSynchronousObservable$1.call(ScalarSynchronousObservable.java:46) at rx.internal.util.ScalarSynchronousObservable$1.call(ScalarSynchronousObservable.java:35) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable.unsafeSubscribe(Observable.java:7710) at rx.internal.operators.OperatorSubscribeOn$1$1.call(OperatorSubscribeOn.java:62) at rx.schedulers.ImmediateScheduler$InnerImmediateScheduler.schedule(ImmediateScheduler.java:58) at rx.internal.operators.OperatorSubscribeOn$1.onNext(OperatorSubscribeOn.java:57) at rx.internal.operators.OperatorSubscribeOn$1.onNext(OperatorSubscribeOn.java:43) at rx.internal.util.ScalarSynchronousObservable$1.call(ScalarSynchronousObservable.java:46) at rx.internal.util.ScalarSynchronousObservable$1.call(ScalarSynchronousObservable.java:35) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable.unsafeSubscribe(Observable.java:7710) at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:231) at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:140) at rx.internal.operators.OperatorMap$1.onNext(OperatorMap.java:55) at rx.internal.operators.OperatorBufferWithSize$1.onNext(OperatorBufferWithSize.java:103) at rx.internal.operators.OnSubscribeFromIterable$IterableProducer.slowpath(OnSubscribeFromIterable.java:97) at rx.internal.operators.OnSubscribeFromIterable$IterableProducer.request(OnSubscribeFromIterable.java:73) at rx.internal.operators.OperatorBufferWithSize$1$1.request(OperatorBufferWithSize.java:88) at rx.Subscriber.setProducer(Subscriber.java:211) at rx.Subscriber.setProducer(Subscriber.java:205) at rx.internal.operators.OperatorBufferWithSize$1.setProducer(OperatorBufferWithSize.java:74) at rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:49) at rx.internal.operators.OnSubscribeFromIterable.call(OnSubscribeFromIterable.java:32) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable.subscribe(Observable.java:7804) at rx.Observable.subscribe(Observable.java:7772) at rx.observables.BlockingObservable.blockForSingle(BlockingObservable.java:432) at rx.observables.BlockingObservable.last(BlockingObservable.java:219) at org.apache.usergrid.persistence.collection.serialization.impl.MvccEntitySerializationStrategyImpl.load(MvccEntitySerializationStrategyImpl. java:223) at org.apache.usergrid.persistence.collection.serialization.impl.MvccEntitySerializationStrategyProxyImpl.load(MvccEntitySerializationStrategy ProxyImpl.java:92) at org.apache.usergrid.persistence.collection.impl.EntityCollectionManagerImpl$1.call(EntityCollectionManagerImpl.java:246) at org.apache.usergrid.persistence.collection.impl.EntityCollectionManagerImpl$1.call(EntityCollectionManagerImpl.java:240) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable$2.call(Observable.java:162) at rx.Observable$2.call(Observable.java:154) at rx.Observable.subscribe(Observable.java:7804) at rx.Observable.subscribe(Observable.java:7772) at rx.observables.BlockingObservable.blockForSingle(BlockingObservable.java:432) at rx.observables.BlockingObservable.lastOrDefault(BlockingObservable.java:252) at org.apache.usergrid.corepersistence.CpEntityManager.load(CpEntityManager.java:325) at org.apache.usergrid.corepersistence.CpEntityManager.getEntity(CpEntityManager.java:514) at org.apache.usergrid.corepersistence.CpEntityManager.get(CpEntityManager.java:481) at org.apache.usergrid.corepersistence.CpEntityManager.getApplication(CpEntityManager.java:737) at org.apache.usergrid.services.ServiceManager.init(ServiceManager.java:101) ... 9 more Caused by: com.netflix.astyanax.connectionpool.exceptions.BadRequestException: BadRequestException: [host=127.0.0.1(127.0.0.1):9160, latency=4(4), att empts=1]InvalidRequestException(why:Keyspace Usergrid_Applications does not exist) at com.netflix.astyanax.thrift.ThriftConverter.ToConnectionPoolException(ThriftConverter.java:159) at com.netflix.astyanax.thrift.ThriftSyncConnectionFactoryImpl$ThriftConnection.execute(ThriftSyncConnectionFactoryImpl.java:137) at com.netflix.astyanax.connectionpool.impl.AbstractExecuteWithFailoverImpl.tryOperation(AbstractExecuteWithFailoverImpl.java:119) at com.netflix.astyanax.connectionpool.impl.AbstractHostPartitionConnectionPool.executeWithFailover(AbstractHostPartitionConnectionPool.java:3 38) at com.netflix.astyanax.thrift.ThriftColumnFamilyQueryImpl$4.execute(ThriftColumnFamilyQueryImpl.java:532) at org.apache.usergrid.persistence.collection.serialization.impl.MvccEntitySerializationStrategyImpl.lambda$null$24(MvccEntitySerializationStr ategyImpl.java:189) ... 86 more Caused by: InvalidRequestException(why:Keyspace Usergrid_Applications does not exist) at org.apache.cassandra.thrift.Cassandra$set_keyspace_result.read(Cassandra.java:5540) at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78) at org.apache.cassandra.thrift.Cassandra$Client.recv_set_keyspace(Cassandra.java:540) at org.apache.cassandra.thrift.Cassandra$Client.set_keyspace(Cassandra.java:527) at com.netflix.astyanax.thrift.ThriftSyncConnectionFactoryImpl$ThriftConnection.execute(ThriftSyncConnectionFactoryImpl.java:125) ... 90 more Caused by: rx.exceptions.OnErrorThrowable$OnNextValue: OnError while emitting onNext value: java.util.ArrayList.class at rx.exceptions.OnErrorThrowable.addValueAsLastCause(OnErrorThrowable.java:104) at rx.internal.operators.OperatorMap$1.onNext(OperatorMap.java:58) ... 84 more 2015-10-30 18:03:06 INFO rest.filters.ContentTypeFilter.init(67)- Starting content type filter 十月 30, 2015 6:03:06 下午 org.apache.catalina.startup.HostConfig deployDirectory 信息: Deploying web application directory D:\server\tomcat7047\webapps\docs 十月 30, 2015 6:03:06 下午 org.apache.catalina.startup.HostConfig deployDirectory 信息: Deploying web application directory D:\server\tomcat7047\webapps\examples 十月 30, 2015 6:03:06 下午 org.apache.catalina.startup.HostConfig deployDirectory 信息: Deploying web application directory D:\server\tomcat7047\webapps\host-manager 十月 30, 2015 6:03:06 下午 org.apache.catalina.startup.HostConfig deployDirectory 信息: Deploying web application directory D:\server\tomcat7047\webapps\manager 十月 30, 2015 6:03:07 下午 org.apache.coyote.AbstractProtocol start 信息: Starting ProtocolHandler ["http-bio-8080"] 十月 30, 2015 6:03:07 下午 org.apache.coyote.AbstractProtocol start 信息: Starting ProtocolHandler ["ajp-bio-8009"] 十月 30, 2015 6:03:07 下午 org.apache.catalina.startup.Catalina start 信息: Server startup in 24136 ms 2015-10-30 18:03:10 INFO batch.service.JobSchedulerService.runOneIteration(97)- Running one check iteration ... 2015-10-30 18:03:10 INFO mq.cassandra.CassandraMQUtils.getQueueId(249)- QueueManagerFactoryImpl.getFromQueue: /jobs/ 2015-10-30 18:03:15 INFO batch.service.JobSchedulerService.runOneIteration(97)- Running one check iteration ...