I having trouble to enable DCP connection.
I receive each time the error message “The DCP service is not enabled or no node in the cluster supports it.”
I set up
System.setProperty("com.couchbase.dcpEnabled", "true") before setting my SparkContext.
I also tried to put it in my configuration set up and as Java options on the Spark master and the spark worker.
I have tried on 2 different environments:
Test -> OSX, Spark 1.6.0 (Sala 10), Sbt + Assembly, Couchbase Server 4.0 Community.
Prod -> Mesos 0.25, Spark 1.6.0, Docker executor, Couchbase Server 4.0 Community on Debian.
I only can get DCP working when I setup the master as “local[*]” but it doesn’t works when I setup the master address “spark://spark-master:7077” (even if it is local address or a remote one).
Any advices on how to unable DCP when using remote servers ?