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

Couchbase JIRA | Sergey Avseyev | 8 months ago
  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 | 8 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 | 8 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 | 1 year 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

    GitHub comment 30#226208334

    GitHub | 6 months ago | jcdesrochers
    java.lang.IllegalStateException: Already released buffer. You released the buffer too many times.
  6. 0

    [jira] Created: (CAMEL-257) Build error from org.apache.camel.component.mina.MinaUdpTest

    camel-dev | 9 years ago | Bozhong Lin (JIRA)
    java.lang.IllegalStateException: Already released buffer. You released the buffer too many times.

    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