java.lang.IllegalStateException: The Content of this Observable is already released. Subscribe earlier or tune the CouchbaseEnvironment#autoreleaseAfter() setting.

Couchbase JIRA | Sergey Avseyev | 12 months ago
tip
Do you know that we can give you better hits? Get more relevant results from Samebug’s stack trace search.
  1. 0

    [~stanley shi] reported that on bucket with 225244 items it raise this exception {noformat} Exception in thread "main" java.lang.IllegalStateException: The Content of this Observable is already released. Subscribe earlier or tune the CouchbaseEnvironment#autoreleaseAfter() setting. at com.couchbase.client.core.utils.UnicastAutoReleaseSubject$OnSubscribeAction.call(UnicastAutoReleaseSubject.java:230) at com.couchbase.client.core.utils.UnicastAutoReleaseSubject$OnSubscribeAction.call(UnicastAutoReleaseSubject.java:202) at rx.Observable.unsafeSubscribe(Observable.java:8171) at rx.subjects.SerializedSubject$1.call(SerializedSubject.java:45) at rx.subjects.SerializedSubject$1.call(SerializedSubject.java:41) at rx.Observable.unsafeSubscribe(Observable.java:8171) 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:54) at rx.internal.producers.SingleDelayedProducer.emit(SingleDelayedProducer.java:102) at rx.internal.producers.SingleDelayedProducer.setValue(SingleDelayedProducer.java:85) at rx.internal.operators.OperatorToObservableList$1.onCompleted(OperatorToObservableList.java:93) at rx.internal.operators.OperatorMerge$MergeSubscriber.emitLoop(OperatorMerge.java:609) at rx.internal.operators.OperatorMerge$MergeSubscriber.emit(OperatorMerge.java:521) at rx.internal.operators.OperatorMerge$InnerSubscriber.onCompleted(OperatorMerge.java:813) at rx.internal.operators.OperatorMap$1.onCompleted(OperatorMap.java:43) at rx.internal.operators.OperatorMerge$MergeSubscriber.emitLoop(OperatorMerge.java:609) at rx.internal.operators.OperatorMerge$MergeSubscriber.emit(OperatorMerge.java:521) at rx.internal.operators.OperatorMerge$InnerSubscriber.onCompleted(OperatorMerge.java:813) at rx.subjects.SubjectSubscriptionManager$SubjectObserver.onCompleted(SubjectSubscriptionManager.java:230) at rx.subjects.AsyncSubject.onCompleted(AsyncSubject.java:102) at com.couchbase.client.core.endpoint.AbstractGenericHandler.completeResponse(AbstractGenericHandler.java:348) at com.couchbase.client.core.endpoint.AbstractGenericHandler.access$000(AbstractGenericHandler.java:71) at com.couchbase.client.core.endpoint.AbstractGenericHandler$1.call(AbstractGenericHandler.java:366) at rx.internal.schedulers.ScheduledAction.run(ScheduledAction.java:55) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) 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) {noformat} changing autoreleaseAfter() does not seem to help {noformat} 2016-03-31 02:31:24 INFO CouchbaseCore:121 - CouchbaseKafkaEnvironment: {sslEnabled=false, sslKeystoreFile='null', sslKeystorePassword='null', queryEnabled=false, queryPort=8093, bootstrapHttpEnabled=true, bootstrapCarrierEnabled=true, bootstrapHttpDirectPort=8091, bootstrapHttpSslPort=18091, bootstrapCarrierDirectPort=11210, bootstrapCarrierSslPort=11207, ioPoolSize=3, computationPoolSize=3, responseBufferSize=16384, requestBufferSize=16384, kvServiceEndpoints=1, viewServiceEndpoints=1, queryServiceEndpoints=1, searchServiceEndpoints=1, ioPool=NioEventLoopGroup, coreScheduler=CoreScheduler, eventBus=DefaultEventBus, packageNameAndVersion=couchbase-jvm-core/1.2.6 (git: 1.2.6), dcpEnabled=true, retryStrategy=BestEffort, maxRequestLifetime=75000, retryDelay=ExponentialDelay {growBy 1.0 MICROSECONDS, powers of 2; lower=100, upper=100000} , reconnectDelay=ExponentialDelay {growBy 1.0 MILLISECONDS, powers of 2; lower=32, upper=4096} , observeIntervalDelay=ExponentialDelay {growBy 1.0 MICROSECONDS, powers of 2; lower=10, upper=100000} , keepAliveInterval=30000, autoreleaseAfter=1500, bufferPoolingEnabled=true, tcpNodelayEnabled=true, mutationTokensEnabled=false, socketConnectTimeout=1000, dcpConnectionBufferSize=20971520, dcpConnectionBufferAckThreshold=0.2, dcpConnectionName=dcp/core-io, callbacksOnIoPool=false, kafkaKeySerializerClass=kafka.serializer.StringEncoder, kafkaFilterClass=com.ebay.Filter, kafkaValueSerializerClass=com.ebay., kafkaEventBufferSize=16384, kafkaTopic=mytopic, kafkaZookeeperAddress=10., couchbaseStateSerializerClass=com.ebay.p13n.cb2kafka.state.LocalFileStateSerializer, couchbaseStateSerializationThreshold=2, couchbaseBucket=mybucket, couchbaseNodes=.ebay.com} {noformat} But everything works with another bucket with 594 items

    Couchbase JIRA | 12 months ago | Sergey Avseyev
    java.lang.IllegalStateException: The Content of this Observable is already released. Subscribe earlier or tune the CouchbaseEnvironment#autoreleaseAfter() setting.
  2. 0

    [~stanley shi] reported that on bucket with 225244 items it raise this exception {noformat} Exception in thread "main" java.lang.IllegalStateException: The Content of this Observable is already released. Subscribe earlier or tune the CouchbaseEnvironment#autoreleaseAfter() setting. at com.couchbase.client.core.utils.UnicastAutoReleaseSubject$OnSubscribeAction.call(UnicastAutoReleaseSubject.java:230) at com.couchbase.client.core.utils.UnicastAutoReleaseSubject$OnSubscribeAction.call(UnicastAutoReleaseSubject.java:202) at rx.Observable.unsafeSubscribe(Observable.java:8171) at rx.subjects.SerializedSubject$1.call(SerializedSubject.java:45) at rx.subjects.SerializedSubject$1.call(SerializedSubject.java:41) at rx.Observable.unsafeSubscribe(Observable.java:8171) 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:54) at rx.internal.producers.SingleDelayedProducer.emit(SingleDelayedProducer.java:102) at rx.internal.producers.SingleDelayedProducer.setValue(SingleDelayedProducer.java:85) at rx.internal.operators.OperatorToObservableList$1.onCompleted(OperatorToObservableList.java:93) at rx.internal.operators.OperatorMerge$MergeSubscriber.emitLoop(OperatorMerge.java:609) at rx.internal.operators.OperatorMerge$MergeSubscriber.emit(OperatorMerge.java:521) at rx.internal.operators.OperatorMerge$InnerSubscriber.onCompleted(OperatorMerge.java:813) at rx.internal.operators.OperatorMap$1.onCompleted(OperatorMap.java:43) at rx.internal.operators.OperatorMerge$MergeSubscriber.emitLoop(OperatorMerge.java:609) at rx.internal.operators.OperatorMerge$MergeSubscriber.emit(OperatorMerge.java:521) at rx.internal.operators.OperatorMerge$InnerSubscriber.onCompleted(OperatorMerge.java:813) at rx.subjects.SubjectSubscriptionManager$SubjectObserver.onCompleted(SubjectSubscriptionManager.java:230) at rx.subjects.AsyncSubject.onCompleted(AsyncSubject.java:102) at com.couchbase.client.core.endpoint.AbstractGenericHandler.completeResponse(AbstractGenericHandler.java:348) at com.couchbase.client.core.endpoint.AbstractGenericHandler.access$000(AbstractGenericHandler.java:71) at com.couchbase.client.core.endpoint.AbstractGenericHandler$1.call(AbstractGenericHandler.java:366) at rx.internal.schedulers.ScheduledAction.run(ScheduledAction.java:55) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) 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) {noformat} changing autoreleaseAfter() does not seem to help {noformat} 2016-03-31 02:31:24 INFO CouchbaseCore:121 - CouchbaseKafkaEnvironment: {sslEnabled=false, sslKeystoreFile='null', sslKeystorePassword='null', queryEnabled=false, queryPort=8093, bootstrapHttpEnabled=true, bootstrapCarrierEnabled=true, bootstrapHttpDirectPort=8091, bootstrapHttpSslPort=18091, bootstrapCarrierDirectPort=11210, bootstrapCarrierSslPort=11207, ioPoolSize=3, computationPoolSize=3, responseBufferSize=16384, requestBufferSize=16384, kvServiceEndpoints=1, viewServiceEndpoints=1, queryServiceEndpoints=1, searchServiceEndpoints=1, ioPool=NioEventLoopGroup, coreScheduler=CoreScheduler, eventBus=DefaultEventBus, packageNameAndVersion=couchbase-jvm-core/1.2.6 (git: 1.2.6), dcpEnabled=true, retryStrategy=BestEffort, maxRequestLifetime=75000, retryDelay=ExponentialDelay {growBy 1.0 MICROSECONDS, powers of 2; lower=100, upper=100000} , reconnectDelay=ExponentialDelay {growBy 1.0 MILLISECONDS, powers of 2; lower=32, upper=4096} , observeIntervalDelay=ExponentialDelay {growBy 1.0 MICROSECONDS, powers of 2; lower=10, upper=100000} , keepAliveInterval=30000, autoreleaseAfter=1500, bufferPoolingEnabled=true, tcpNodelayEnabled=true, mutationTokensEnabled=false, socketConnectTimeout=1000, dcpConnectionBufferSize=20971520, dcpConnectionBufferAckThreshold=0.2, dcpConnectionName=dcp/core-io, callbacksOnIoPool=false, kafkaKeySerializerClass=kafka.serializer.StringEncoder, kafkaFilterClass=com.ebay.Filter, kafkaValueSerializerClass=com.ebay., kafkaEventBufferSize=16384, kafkaTopic=mytopic, kafkaZookeeperAddress=10., couchbaseStateSerializerClass=com.ebay.p13n.cb2kafka.state.LocalFileStateSerializer, couchbaseStateSerializationThreshold=2, couchbaseBucket=mybucket, couchbaseNodes=.ebay.com} {noformat} But everything works with another bucket with 594 items

    Couchbase JIRA | 12 months ago | Sergey Avseyev
    java.lang.IllegalStateException: The Content of this Observable is already released. Subscribe earlier or tune the CouchbaseEnvironment#autoreleaseAfter() setting.
  3. 0

    Illegal State Exception with couchbase

    Stack Overflow | 2 years ago | suman35
    java.lang.IllegalStateException: The Content of this Observable is already released. Subscribe earlier or tune the CouchbaseEnvironment#autoreleaseAfter() setting.
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    How can I cope with "IllegalStateException: BeanFactory not initialized or already closed"?

    Stack Overflow | 6 years ago | user569825
    java.lang.IllegalStateException: BeanFactory not initialized or already closed - call 'refresh' before accessing beans via the ApplicationContext
  6. 0

    issues in spring petclinic applicaiton

    Stack Overflow | 4 years ago | user2216702
    java.lang.IllegalStateException: ApplicationEventMulticaster not initialized - c all 'refresh' before multicasting events via the context: Root WebApplicationCon text: startup date [Wed Mar 27 11:31:56 CDT 2013]; root of context hierarchy at org.springframework.context.support.AbstractApplic ationContext.getApp licationEventMulticaster(AbstractApplicationContex t.java:347) [spring-context-3. 2.2.RELEASE.jar:3.2.2.RELEASE] at org.springframework.context.support.AbstractApplic ationContext.publis hEvent(AbstractApplicationContext.java:334) [spring-context-3.2.2.RELEASE.jar:3. 2.2.RELEASE] at org.springframework.context.support.AbstractApplic ationContext.doClos e(AbstractApplicationContext.java:1049) [spring-context-3.2.2.RELEASE.jar:3.2.2. RELEASE] at org.springframework.context.support.AbstractApplic ationContext.close( AbstractApplicationContext.java:1010) [spring-context-3.2.2.RELEASE.jar:3.2.2.RE LEASE] at org.springframework.web.context.ContextLoader.clos eWebApplicationCont ext(ContextLoader.java:558) [spring-web-3.2.2.RELEASE.jar:3.2.2.RELEASE] at org.springframework.web.context.ContextLoaderListe ner.contextDestroye d(ContextLoaderListener.java:143) [spring-web-3.2.2.RELEASE.jar:3.2.2.RELEASE] at org.apache.catalina.core.StandardContext.listenerS top(StandardContext .java:4831) [tomcat-embed-core-7.0.30.jar:7.0.30] at org.apache.catalina.core.StandardContext.stopInter nal(StandardContext .java:5478) [tomcat-embed-core-7.0.30.jar:7.0.30] at org.apache.catalina.util.LifecycleBase.stop(Lifecy cleBase.java:232) [ tomcat-embed-core-7.0.30.jar:7.0.30] at org.apache.catalina.util.LifecycleBase.start(Lifec ycleBase.java:160) [tomcat-embed-core-7.0.30.jar:7.0.30] at org.apache.catalina.core.ContainerBase$StartChild. call(ContainerBase. java:1559) [tomcat-embed-core-7.0.30.jar:7.0.30] at org.apache.catalina.core.ContainerBase$StartChild. call(ContainerBase. java:1549) [tomcat-embed-core-7.0.30.jar:7.0.30] at java.util.concurrent.FutureTask$Sync.innerRun(Futu reTask.java:303) [n a:1.6.0_20] at java.util.concurrent.FutureTask.run(FutureTask.jav a:138) [na:1.6.0_20 ] at java.util.concurrent.ThreadPoolExecutor$Worker.run Task(ThreadPoolExec utor.java:886) [na:1.6.0_20] at java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor .java:908) [na:1.6.0_20]

    2 unregistered visitors
    Not finding the right solution?
    Take a tour to get the most out of Samebug.

    Tired of useless tips?

    Automated exception search integrated into your IDE

    Root Cause Analysis

    1. java.lang.IllegalStateException

      The Content of this Observable is already released. Subscribe earlier or tune the CouchbaseEnvironment#autoreleaseAfter() setting.

      at com.couchbase.client.core.utils.UnicastAutoReleaseSubject$OnSubscribeAction.call()
    2. com.couchbase.client
      UnicastAutoReleaseSubject$OnSubscribeAction.call
      1. com.couchbase.client.core.utils.UnicastAutoReleaseSubject$OnSubscribeAction.call(UnicastAutoReleaseSubject.java:230)
      2. com.couchbase.client.core.utils.UnicastAutoReleaseSubject$OnSubscribeAction.call(UnicastAutoReleaseSubject.java:202)
      2 frames
    3. rxjava
      OperatorMap$1.onNext
      1. rx.Observable.unsafeSubscribe(Observable.java:8171)
      2. rx.subjects.SerializedSubject$1.call(SerializedSubject.java:45)
      3. rx.subjects.SerializedSubject$1.call(SerializedSubject.java:41)
      4. rx.Observable.unsafeSubscribe(Observable.java:8171)
      5. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:231)
      6. rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:140)
      7. rx.internal.operators.OperatorMap$1.onNext(OperatorMap.java:54)
      7 frames
    4. rx.internal.producers
      SingleDelayedProducer.setValue
      1. rx.internal.producers.SingleDelayedProducer.emit(SingleDelayedProducer.java:102)
      2. rx.internal.producers.SingleDelayedProducer.setValue(SingleDelayedProducer.java:85)
      2 frames
    5. rxjava
      AsyncSubject.onCompleted
      1. rx.internal.operators.OperatorToObservableList$1.onCompleted(OperatorToObservableList.java:93)
      2. rx.internal.operators.OperatorMerge$MergeSubscriber.emitLoop(OperatorMerge.java:609)
      3. rx.internal.operators.OperatorMerge$MergeSubscriber.emit(OperatorMerge.java:521)
      4. rx.internal.operators.OperatorMerge$InnerSubscriber.onCompleted(OperatorMerge.java:813)
      5. rx.internal.operators.OperatorMap$1.onCompleted(OperatorMap.java:43)
      6. rx.internal.operators.OperatorMerge$MergeSubscriber.emitLoop(OperatorMerge.java:609)
      7. rx.internal.operators.OperatorMerge$MergeSubscriber.emit(OperatorMerge.java:521)
      8. rx.internal.operators.OperatorMerge$InnerSubscriber.onCompleted(OperatorMerge.java:813)
      9. rx.subjects.SubjectSubscriptionManager$SubjectObserver.onCompleted(SubjectSubscriptionManager.java:230)
      10. rx.subjects.AsyncSubject.onCompleted(AsyncSubject.java:102)
      10 frames
    6. com.couchbase.client
      AbstractGenericHandler$1.call
      1. com.couchbase.client.core.endpoint.AbstractGenericHandler.completeResponse(AbstractGenericHandler.java:348)
      2. com.couchbase.client.core.endpoint.AbstractGenericHandler.access$000(AbstractGenericHandler.java:71)
      3. com.couchbase.client.core.endpoint.AbstractGenericHandler$1.call(AbstractGenericHandler.java:366)
      3 frames
    7. rxjava
      ScheduledAction.run
      1. rx.internal.schedulers.ScheduledAction.run(ScheduledAction.java:55)
      1 frame
    8. Java RT
      Thread.run
      1. java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
      2. java.util.concurrent.FutureTask.run(FutureTask.java:266)
      3. java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
      4. java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
      5. java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
      6. java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
      7. java.lang.Thread.run(Thread.java:745)
      7 frames