'State needs to be initialized or recovered first before starting' after initializing

java.lang.IllegalStateException: State needs to be initialized or recovered first before starting

	at com.couchbase.client.dcp.Client.sanityCheckSessionState(Client.java:370)

	at com.couchbase.client.dcp.Client.startStreaming(Client.java:317)

	at com.couchbase.analytics.adapter.CouchbaseConnector.<init>(CouchbaseConnector.java:73)

        LOGGER.info(feedName + " calling initializeState()...");

        if (!client.initializeState(StreamFrom.BEGINNING, StreamTo.INFINITY).await(TIMEOUT_SECS, TimeUnit.SECONDS)) {

            throw new HyracksDataException("client.initializeStream().await() timed out after " + TIMEOUT_SECS

                    + " seconds");

        }

        LOGGER.info(feedName + " ...state initialized");

        LOGGER.info(feedName + " calling startStreaming().subscribe()...");

        // TODO (amoudi/mblow): any way to timeout for startStreaming().subscribe()?

        subscription = client.startStreaming(vbuckets).subscribe();