Remove cassandra example

02370e52 · Manuel de Brito Fontes · 19f592e4 · 02370e52 · 02370e52 · 19f592e4
Unverified Commit 02370e52 authored Feb 26, 2018 by Manuel de Brito Fontes
33 changed files
--- a/examples/examples_test.go
+++ b/examples/examples_test.go
@@ -221,12 +221,6 @@ func TestExampleObjectSchemas(t *testing.T) {
 			"rbd":             &api.Pod{},
 			"rbd-with-secret": &api.Pod{},
 		},
-		"../examples/storage/cassandra": {
-			"cassandra-daemonset":   &extensions.DaemonSet{},
-			"cassandra-controller":  &api.ReplicationController{},
-			"cassandra-service":     &api.Service{},
-			"cassandra-statefulset": &apps.StatefulSet{},
-		},
 		"../examples/cluster-dns": {
 			"dns-backend-rc":      &api.ReplicationController{},
 			"dns-backend-service": &api.Service{},

--- a/examples/storage/cassandra/README.md
+++ b/examples/storage/cassandra/README.md
-This file has moved to [https://github.com/kubernetes/examples/blob/master/cassandra/README.md](https://github.com/kubernetes/examples/blob/master/cassandra/README.md)
+This example has been moved to [https://github.com/kubernetes/examples/blob/master/cassandra](https://github.com/kubernetes/examples/blob/master/cassandra)
--- a/examples/storage/cassandra/cassandra-daemonset.yaml
+++ b/examples/storage/cassandra/cassandra-daemonset.yaml
-apiVersion: extensions/v1beta1
-kind: DaemonSet
-metadata:
-  labels:
-    name: cassandra
-  name: cassandra
-spec:
-  template:
-    metadata:
-      labels:
-        app: cassandra
-    spec:
-      # Filter to specific nodes:
-      # nodeSelector:
-      #  app: cassandra
-      containers:
-        - command:
-            - /run.sh
-          env:
-            - name: MAX_HEAP_SIZE
-              value: 512M
-            - name: HEAP_NEWSIZE
-              value: 100M
-            - name: CASSANDRA_SEED_PROVIDER
-              value: "io.k8s.cassandra.KubernetesSeedProvider"
-            - name: POD_NAMESPACE
-              valueFrom:
-                fieldRef:
-                  fieldPath: metadata.namespace
-            - name: POD_IP
-              valueFrom:
-                fieldRef:
-                  fieldPath: status.podIP
-          image: gcr.io/google-samples/cassandra:v12
-          name: cassandra
-          ports:
-            - containerPort: 7000
-              name: intra-node
-            - containerPort: 7001
-              name: tls-intra-node
-            - containerPort: 7199
-              name: jmx
-            - containerPort: 9042
-              name: cql
-              # If you need it it is going away in C* 4.0
-              #- containerPort: 9160
-              #  name: thrift
-          resources:
-            requests:
-              cpu: 0.5
-          volumeMounts:
-            - mountPath: /cassandra_data
-              name: data
-      volumes:
-        - name: data
-          emptyDir: {}
--- a/examples/storage/cassandra/cassandra-service.yaml
+++ b/examples/storage/cassandra/cassandra-service.yaml
-apiVersion: v1
-kind: Service
-metadata:
-  labels:
-    app: cassandra
-  name: cassandra
-spec:
-  clusterIP: None
-  ports:
-    - port: 9042
-  selector:
-    app: cassandra
--- a/examples/storage/cassandra/cassandra-statefulset.yaml
+++ b/examples/storage/cassandra/cassandra-statefulset.yaml
-apiVersion: "apps/v1beta1"
-kind: StatefulSet
-metadata:
-  name: cassandra
-spec:
-  serviceName: cassandra
-  replicas: 3
-  template:
-    metadata:
-      labels:
-        app: cassandra
-    spec:
-      terminationGracePeriodSeconds: 1800
-      containers:
-      - name: cassandra
-        image: gcr.io/google-samples/cassandra:v12
-        imagePullPolicy: Always
-        ports:
-        - containerPort: 7000
-          name: intra-node
-        - containerPort: 7001
-          name: tls-intra-node
-        - containerPort: 7199
-          name: jmx
-        - containerPort: 9042
-          name: cql
-        resources:
-          limits:
-            cpu: "500m"
-            memory: 1Gi
-          requests:
-           cpu: "500m"
-           memory: 1Gi
-        securityContext:
-          capabilities:
-            add:
-              - IPC_LOCK
-        lifecycle:
-          preStop:
-            exec:
-              command: ["/bin/sh", "-c", "nodetool drain"]
-        env:
-          - name: MAX_HEAP_SIZE
-            value: 512M
-          - name: HEAP_NEWSIZE
-            value: 100M
-          - name: CASSANDRA_SEEDS
-            value: "cassandra-0.cassandra.default.svc.cluster.local"
-          - name: CASSANDRA_CLUSTER_NAME
-            value: "K8Demo"
-          - name: CASSANDRA_DC
-            value: "DC1-K8Demo"
-          - name: CASSANDRA_RACK
-            value: "Rack1-K8Demo"
-          - name: CASSANDRA_AUTO_BOOTSTRAP
-            value: "false"
-          - name: POD_IP
-            valueFrom:
-              fieldRef:
-                fieldPath: status.podIP
-          - name: POD_NAMESPACE
-            valueFrom:
-              fieldRef:
-                fieldPath: metadata.namespace
-        readinessProbe:
-          exec:
-            command:
-            - /bin/bash
-            - -c
-            - /ready-probe.sh
-          initialDelaySeconds: 15
-          timeoutSeconds: 5
-        # These volume mounts are persistent. They are like inline claims,
-        # but not exactly because the names need to match exactly one of
-        # the stateful pod volumes.
-        volumeMounts:
-        - name: cassandra-data
-          mountPath: /cassandra_data
-  # These are converted to volume claims by the controller
-  # and mounted at the paths mentioned above.
-  # do not use these in production until ssd GCEPersistentDisk or other ssd pd
-  volumeClaimTemplates:
-  - metadata:
-      name: cassandra-data
-    spec:
-      accessModes: [ "ReadWriteOnce" ]
-      resources:
-        requests:
-          storage: 1Gi
-      storageClassName: fast
---
-kind: StorageClass
-apiVersion: storage.k8s.io/v1
-metadata:
-  name: fast
-provisioner: kubernetes.io/gce-pd
-parameters:
-  type: pd-ssd
--- a/examples/storage/cassandra/image/Dockerfile
+++ b/examples/storage/cassandra/image/Dockerfile
-# Copyright 2017 The Kubernetes Authors.
-#
-# Licensed under the Apache License, Version 2.0 (the "License");
-# you may not use this file except in compliance with the License.
-# You may obtain a copy of the License at
-#
-#     http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-FROM k8s.gcr.io/ubuntu-slim:0.9
-ARG BUILD_DATE
-ARG VCS_REF
-ARG CASSANDRA_VERSION
-ARG DEV_CONTAINER
-LABEL \
-    org.label-schema.build-date=$BUILD_DATE \
-    org.label-schema.docker.dockerfile="/Dockerfile" \
-    org.label-schema.license="Apache License 2.0" \
-    org.label-schema.name="k8s-for-greeks/docker-cassandra-k8s" \
-    org.label-schema.url="https://github.com/k8s-for-greeks/" \
-    org.label-schema.vcs-ref=$VCS_REF \
-    org.label-schema.vcs-type="Git" \
-    org.label-schema.vcs-url="https://github.com/k8s-for-greeks/docker-cassandra-k8s"
-ENV CASSANDRA_HOME=/usr/local/apache-cassandra-${CASSANDRA_VERSION} \
-    CASSANDRA_CONF=/etc/cassandra \
-    CASSANDRA_DATA=/cassandra_data \
-    CASSANDRA_LOGS=/var/log/cassandra \
-    JAVA_HOME=/usr/lib/jvm/java-8-openjdk-amd64 \
-    PATH=${PATH}:/usr/lib/jvm/java-8-openjdk-amd64/bin:/usr/local/apache-cassandra-${CASSANDRA_VERSION}/bin  \
-    DI_VERSION=1.2.0 \
-    DI_SHA=81231da1cd074fdc81af62789fead8641ef3f24b6b07366a1c34e5b059faf363
-ADD files /
-RUN set -e && echo 'debconf debconf/frontend select Noninteractive' | debconf-set-selections \
-  && apt-get update && apt-get -qq -y --force-yes install --no-install-recommends \
-    openjdk-8-jre-headless \
-    libjemalloc1 \
-    localepurge \
-    wget && \
-  mirror_url=$( wget -q -O - http://www.apache.org/dyn/closer.cgi/cassandra/ \
-        | sed -n 's#.*href="\(http://.*/cassandra\/[^"]*\)".*#\1#p' \
-        | head -n 1 \
-    ) \
-    && wget -q -O - ${mirror_url}/${CASSANDRA_VERSION}/apache-cassandra-${CASSANDRA_VERSION}-bin.tar.gz \
-        | tar -xzf - -C /usr/local \
-    && wget -q -O - https://github.com/Yelp/dumb-init/releases/download/v${DI_VERSION}/dumb-init_${DI_VERSION}_amd64 > /sbin/dumb-init \
-    && echo "$DI_SHA  /sbin/dumb-init" | sha256sum -c - \
-    && chmod +x /sbin/dumb-init \
-    && chmod +x /ready-probe.sh \
-    && mkdir -p /cassandra_data/data \
-    && mkdir -p /etc/cassandra \
-    && mv /logback.xml /cassandra.yaml /jvm.options /etc/cassandra/ \
-    && mv /usr/local/apache-cassandra-${CASSANDRA_VERSION}/conf/cassandra-env.sh /etc/cassandra/ \
-    && adduser --disabled-password --no-create-home --gecos '' --disabled-login cassandra \
-    && chown cassandra: /ready-probe.sh \
-    && if [ -n "$DEV_CONTAINER" ]; then apt-get -y --no-install-recommends install python; else rm -rf  $CASSANDRA_HOME/pylib; fi \
-    && apt-get -y purge wget localepurge \
-    && apt-get -y autoremove \
-    && apt-get clean \
-    && rm -rf \
-        $CASSANDRA_HOME/*.txt \
-        $CASSANDRA_HOME/doc \
-        $CASSANDRA_HOME/javadoc \
-        $CASSANDRA_HOME/tools/*.yaml \
-        $CASSANDRA_HOME/tools/bin/*.bat \
-        $CASSANDRA_HOME/bin/*.bat \
-    doc \
-    man \
-    info \
-    locale \
-    common-licenses \
-    ~/.bashrc \
-        /var/lib/apt/lists/* \
-        /var/log/* \
-        /var/cache/debconf/* \
-        /etc/systemd \
-        /lib/lsb \
-        /lib/udev \
-        /usr/share/doc/ \
-        /usr/share/doc-base/ \
-        /usr/share/man/ \
-        /tmp/* \
-        /usr/lib/jvm/java-8-openjdk-amd64/jre/plugin \
-        /usr/lib/jvm/java-8-openjdk-amd64/jre/bin/javaws \
-        /usr/lib/jvm/java-8-openjdk-amd64/jre/bin/jjs \
-        /usr/lib/jvm/java-8-openjdk-amd64/jre/bin/orbd \
-        /usr/lib/jvm/java-8-openjdk-amd64/bin/pack200 \
-        /usr/lib/jvm/java-8-openjdk-amd64/jre/bin/policytool \
-        /usr/lib/jvm/java-8-openjdk-amd64/jre/bin/rmid \
-        /usr/lib/jvm/java-8-openjdk-amd64/jre/bin/rmiregistry \
-        /usr/lib/jvm/java-8-openjdk-amd64/jre/bin/servertool \
-        /usr/lib/jvm/java-8-openjdk-amd64/bin/tnameserv \
-        /usr/lib/jvm/java-8-openjdk-amd64/jre/bin/unpack200 \
-        /usr/lib/jvm/java-8-openjdk-amd64/jre/lib/javaws.jar \
-        /usr/lib/jvm/java-8-openjdk-amd64/jre/lib/deploy* \
-        /usr/lib/jvm/java-8-openjdk-amd64/jre/lib/desktop \
-        /usr/lib/jvm/java-8-openjdk-amd64/jre/lib/*javafx* \
-        /usr/lib/jvm/java-8-openjdk-amd64/jre/lib/*jfx* \
-        /usr/lib/jvm/java-8-openjdk-amd64/jre/lib/amd64/libdecora_sse.so \
-        /usr/lib/jvm/java-8-openjdk-amd64/jre/lib/amd64/libprism_*.so \
-        /usr/lib/jvm/java-8-openjdk-amd64/jre/lib/amd64/libfxplugins.so \
-        /usr/lib/jvm/java-8-openjdk-amd64/jre/lib/amd64/libglass.so \
-        /usr/lib/jvm/java-8-openjdk-amd64/jre/lib/amd64/libgstreamer-lite.so \
-        /usr/lib/jvm/java-8-openjdk-amd64/jre/lib/amd64/libjavafx*.so \
-        /usr/lib/jvm/java-8-openjdk-amd64/jre/lib/amd64/libjfx*.so \
-        /usr/lib/jvm/java-8-openjdk-amd64/jre/lib/ext/jfxrt.jar \
-        /usr/lib/jvm/java-8-openjdk-amd64/jre/lib/ext/nashorn.jar \
-        /usr/lib/jvm/java-8-openjdk-amd64/jre/lib/oblique-fonts \
-        /usr/lib/jvm/java-8-openjdk-amd64/jre/lib/plugin.jar \
-        /usr/lib/jvm/java-8-openjdk-amd64/man
-VOLUME ["/$CASSANDRA_DATA"]
-# 7000: intra-node communication
-# 7001: TLS intra-node communication
-# 7199: JMX
-# 9042: CQL
-# 9160: thrift service
-EXPOSE 7000 7001 7199 9042 9160
-CMD ["/sbin/dumb-init", "/bin/bash", "/run.sh"]
--- a/examples/storage/cassandra/image/Makefile
+++ b/examples/storage/cassandra/image/Makefile
-# Copyright 2016 The Kubernetes Authors.
-#
-# Licensed under the Apache License, Version 2.0 (the "License");
-# you may not use this file except in compliance with the License.
-# You may obtain a copy of the License at
-#
-#     http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-# build the cassandra image.
-VERSION=v12
-PROJECT_ID?=google_samples
-PROJECT=gcr.io/${PROJECT_ID}
-CASSANDRA_VERSION=3.10
-all: kubernetes-cassandra.jar build
-kubernetes-cassandra.jar: ../java/* ../java/src/main/java/io/k8s/cassandra/*.java
-	cd ../java && mvn clean && mvn package
-	mv ../java/target/kubernetes-cassandra*.jar files/kubernetes-cassandra.jar
-	cd ../java && mvn clean
-container:
-	@echo "Building ${PROJECT}/cassandra:${VERSION}"
-	docker build --pull --build-arg "CASSANDRA_VERSION=${CASSANDRA_VERSION}" -t ${PROJECT}/cassandra:${VERSION} .
-container-dev:
-	docker build --pull --build-arg "CASSANDRA_VERSION=${CASSANDRA_VERSION}" --build-arg "DEV_CONTAINER=true" -t ${PROJECT}/cassandra:${VERSION}-dev .
-build: container container-dev
-push: build
-	gcloud docker -- push ${PROJECT}/cassandra:${VERSION}
-	gcloud docker -- push ${PROJECT}/cassandra:${VERSION}-dev
-.PHONY: all build push
--- a/examples/storage/cassandra/image/files/cassandra.yaml
+++ b/examples/storage/cassandra/image/files/cassandra.yaml
--- a/examples/storage/cassandra/image/files/jvm.options
+++ b/examples/storage/cassandra/image/files/jvm.options
-###########################################################################
-#                             jvm.options                                 #
-#                                                                         #
-# - all flags defined here will be used by cassandra to startup the JVM   #
-# - one flag should be specified per line                                 #
-# - lines that do not start with '-' will be ignored                      #
-# - only static flags are accepted (no variables or parameters)           #
-# - dynamic flags will be appended to these on cassandra-env              #
-###########################################################################
-######################
-# STARTUP PARAMETERS #
-######################
-# Uncomment any of the following properties to enable specific startup parameters
-# In a multi-instance deployment, multiple Cassandra instances will independently assume that all
-# CPU processors are available to it. This setting allows you to specify a smaller set of processors
-# and perhaps have affinity.
-#-Dcassandra.available_processors=number_of_processors
-# The directory location of the cassandra.yaml file.
-#-Dcassandra.config=directory
-# Sets the initial partitioner token for a node the first time the node is started.
-#-Dcassandra.initial_token=token
-# Set to false to start Cassandra on a node but not have the node join the cluster.
-#-Dcassandra.join_ring=true|false
-# Set to false to clear all gossip state for the node on restart. Use when you have changed node
-# information in cassandra.yaml (such as listen_address).
-#-Dcassandra.load_ring_state=true|false
-# Enable pluggable metrics reporter. See Pluggable metrics reporting in Cassandra 2.0.2.
-#-Dcassandra.metricsReporterConfigFile=file
-# Set the port on which the CQL native transport listens for clients. (Default: 9042)
-#-Dcassandra.native_transport_port=port
-# Overrides the partitioner. (Default: org.apache.cassandra.dht.Murmur3Partitioner)
-#-Dcassandra.partitioner=partitioner
-# To replace a node that has died, restart a new node in its place specifying the address of the
-# dead node. The new node must not have any data in its data directory, that is, it must be in the
-# same state as before bootstrapping.
-#-Dcassandra.replace_address=listen_address or broadcast_address of dead node
-# Allow restoring specific tables from an archived commit log.
-#-Dcassandra.replayList=table
-# Allows overriding of the default RING_DELAY (1000ms), which is the amount of time a node waits
-# before joining the ring.
-#-Dcassandra.ring_delay_ms=ms
-# Set the port for the Thrift RPC service, which is used for client connections. (Default: 9160)
-#-Dcassandra.rpc_port=port
-# Set the SSL port for encrypted communication. (Default: 7001)
-#-Dcassandra.ssl_storage_port=port
-# Enable or disable the native transport server. See start_native_transport in cassandra.yaml.
-# cassandra.start_native_transport=true|false
-# Enable or disable the Thrift RPC server. (Default: true)
-#-Dcassandra.start_rpc=true/false
-# Set the port for inter-node communication. (Default: 7000)
-#-Dcassandra.storage_port=port
-# Set the default location for the trigger JARs. (Default: conf/triggers)
-#-Dcassandra.triggers_dir=directory
-# For testing new compaction and compression strategies. It allows you to experiment with different
-# strategies and benchmark write performance differences without affecting the production workload.
-#-Dcassandra.write_survey=true
-# To disable configuration via JMX of auth caches (such as those for credentials, permissions and
-# roles). This will mean those config options can only be set (persistently) in cassandra.yaml
-# and will require a restart for new values to take effect.
-#-Dcassandra.disable_auth_caches_remote_configuration=true
-########################
-# GENERAL JVM SETTINGS #
-########################
-# enable assertions.  disabling this in production will give a modest
-# performance benefit (around 5%).
-ea
-# enable thread priorities, primarily so we can give periodic tasks
-# a lower priority to avoid interfering with client workload
-XX:+UseThreadPriorities
-# allows lowering thread priority without being root on linux - probably
-# not necessary on Windows but doesn't harm anything.
-# see http://tech.stolsvik.com/2010/01/linux-java-thread-priorities-workar
-XX:ThreadPriorityPolicy=42
-# Enable heap-dump if there's an OOM
-XX:+HeapDumpOnOutOfMemoryError
-# Per-thread stack size.
-Xss256k
-# Larger interned string table, for gossip's benefit (CASSANDRA-6410)
-XX:StringTableSize=1000003
-# Make sure all memory is faulted and zeroed on startup.
-# This helps prevent soft faults in containers and makes
-# transparent hugepage allocation more effective.
-XX:+AlwaysPreTouch
-# Disable biased locking as it does not benefit Cassandra.
-XX:-UseBiasedLocking
-# Enable thread-local allocation blocks and allow the JVM to automatically
-# resize them at runtime.
-XX:+UseTLAB
-XX:+ResizeTLAB
-# http://www.evanjones.ca/jvm-mmap-pause.html
-XX:+PerfDisableSharedMem
-# Prefer binding to IPv4 network intefaces (when net.ipv6.bindv6only=1). See
-# http://bugs.sun.com/bugdatabase/view_bug.do?bug_id=6342561 (short version:
-# comment out this entry to enable IPv6 support).
-Djava.net.preferIPv4Stack=true
-### Debug options
-# uncomment to enable flight recorder
-#-XX:+UnlockCommercialFeatures
-#-XX:+FlightRecorder
-# uncomment to have Cassandra JVM listen for remote debuggers/profilers on port 1414
-#-agentlib:jdwp=transport=dt_socket,server=y,suspend=n,address=1414
-# uncomment to have Cassandra JVM log internal method compilation (developers only)
-#-XX:+UnlockDiagnosticVMOptions
-#-XX:+LogCompilation
-#################
-# HEAP SETTINGS #
-#################
-# Heap size is automatically calculated by cassandra-env based on this
-# formula: max(min(1/2 ram, 1024MB), min(1/4 ram, 8GB))
-# That is:
-# - calculate 1/2 ram and cap to 1024MB
-# - calculate 1/4 ram and cap to 8192MB
-# - pick the max
-#
-# For production use you may wish to adjust this for your environment.
-# If that's the case, uncomment the -Xmx and Xms options below to override the
-# automatic calculation of JVM heap memory.
-#
-# It is recommended to set min (-Xms) and max (-Xmx) heap sizes to
-# the same value to avoid stop-the-world GC pauses during resize, and
-# so that we can lock the heap in memory on startup to prevent any
-# of it from being swapped out.
-#-Xms4G
-#-Xmx4G
-# Young generation size is automatically calculated by cassandra-env
-# based on this formula: min(100 * num_cores, 1/4 * heap size)
-#
-# The main trade-off for the young generation is that the larger it
-# is, the longer GC pause times will be. The shorter it is, the more
-# expensive GC will be (usually).
-#
-# It is not recommended to set the young generation size if using the
-# G1 GC, since that will override the target pause-time goal.
-# More info: http://www.oracle.com/technetwork/articles/java/g1gc-1984535.html
-#
-# The example below assumes a modern 8-core+ machine for decent
-# times. If in doubt, and if you do not particularly want to tweak, go
-# 100 MB per physical CPU core.
-#-Xmn800M
-#################
-#  GC SETTINGS  #
-#################
-### CMS Settings
-#-XX:+UseParNewGC
-#-XX:+UseConcMarkSweepGC
-#-XX:+CMSParallelRemarkEnabled
-#-XX:SurvivorRatio=8
-#-XX:MaxTenuringThreshold=1
-#-XX:CMSInitiatingOccupancyFraction=75
-#-XX:+UseCMSInitiatingOccupancyOnly
-#-XX:CMSWaitDuration=10000
-#-XX:+CMSParallelInitialMarkEnabled
-#-XX:+CMSEdenChunksRecordAlways
-# some JVMs will fill up their heap when accessed via JMX, see CASSANDRA-6541
-#-XX:+CMSClassUnloadingEnabled
-### G1 Settings (experimental, comment previous section and uncomment section below to enable)
-## Use the Hotspot garbage-first collector.
-XX:+UseG1GC
-#
-## Have the JVM do less remembered set work during STW, instead
-## preferring concurrent GC. Reduces p99.9 latency.
-XX:G1RSetUpdatingPauseTimePercent=5
-#
-## Main G1GC tunable: lowering the pause target will lower throughput and vise versa.
-## 200ms is the JVM default and lowest viable setting
-## 1000ms increases throughput. Keep it smaller than the timeouts in cassandra.yaml.
-#-XX:MaxGCPauseMillis=500
-## Optional G1 Settings
-# Save CPU time on large (>= 16GB) heaps by delaying region scanning
-# until the heap is 70% full. The default in Hotspot 8u40 is 40%.
-#-XX:InitiatingHeapOccupancyPercent=70
-# For systems with > 8 cores, the default ParallelGCThreads is 5/8 the number of logical cores.
-# Otherwise equal to the number of cores when 8 or less.
-# Machines with > 10 cores should try setting these to <= full cores.
-#-XX:ParallelGCThreads=16
-# By default, ConcGCThreads is 1/4 of ParallelGCThreads.
-# Setting both to the same value can reduce STW durations.
-#-XX:ConcGCThreads=16
-### GC logging options -- uncomment to enable
-XX:+PrintGCDetails
-XX:+PrintGCDateStamps
-XX:+PrintHeapAtGC
-XX:+PrintTenuringDistribution
-XX:+PrintGCApplicationStoppedTime
-XX:+PrintPromotionFailure
-#-XX:PrintFLSStatistics=1
-#-Xloggc:/var/log/cassandra/gc.log
-XX:+UseGCLogFileRotation
-XX:NumberOfGCLogFiles=10
-XX:GCLogFileSize=10M
--- a/examples/storage/cassandra/image/files/kubernetes-cassandra.jar
+++ b/examples/storage/cassandra/image/files/kubernetes-cassandra.jar
--- a/examples/storage/cassandra/image/files/logback.xml
+++ b/examples/storage/cassandra/image/files/logback.xml
-<?xml version="1.0"?>
-<configuration scan="true">
-  <jmxConfigurator/>
-  <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
-    <encoder>
-      <pattern>%-5level %date{HH:mm:ss,SSS} %msg%n</pattern>
-    </encoder>
-  </appender>
-  <root level="INFO">
-    <appender-ref ref="STDOUT"/>
-  </root>
-  <logger name="com.thinkaurelius.thrift" level="ERROR"/>
-</configuration>
\ No newline at end of file
--- a/examples/storage/cassandra/image/files/ready-probe.sh
+++ b/examples/storage/cassandra/image/files/ready-probe.sh
-#!/bin/bash
-# Copyright 2016 The Kubernetes Authors.
-#
-# Licensed under the Apache License, Version 2.0 (the "License");
-# you may not use this file except in compliance with the License.
-# You may obtain a copy of the License at
-#
-#     http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-if [[ $(nodetool status | grep $POD_IP) == *"UN"* ]]; then
-  if [[ $DEBUG ]]; then
-    echo "UN";
-  fi
-  exit 0;
-else
-  if [[ $DEBUG ]]; then
-    echo "Not Up";
-  fi
-  exit 1;
-fi
--- a/examples/storage/cassandra/image/files/run.sh
+++ b/examples/storage/cassandra/image/files/run.sh
-#!/bin/bash
-# Copyright 2016 The Kubernetes Authors.
-#
-# Licensed under the Apache License, Version 2.0 (the "License");
-# you may not use this file except in compliance with the License.
-# You may obtain a copy of the License at
-#
-#     http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-set -e
-CASSANDRA_CONF_DIR=/etc/cassandra
-CASSANDRA_CFG=$CASSANDRA_CONF_DIR/cassandra.yaml
-# we are doing StatefulSet or just setting our seeds
-if [ -z "$CASSANDRA_SEEDS" ]; then
-  HOSTNAME=$(hostname -f)
-  CASSANDRA_SEEDS=$(hostname -f)
-fi
-# The following vars relate to there counter parts in $CASSANDRA_CFG
-# for instance rpc_address
-CASSANDRA_RPC_ADDRESS="${CASSANDRA_RPC_ADDRESS:-0.0.0.0}"
-CASSANDRA_NUM_TOKENS="${CASSANDRA_NUM_TOKENS:-32}"
-CASSANDRA_CLUSTER_NAME="${CASSANDRA_CLUSTER_NAME:='Test Cluster'}"
-CASSANDRA_LISTEN_ADDRESS=${POD_IP:-$HOSTNAME}
-CASSANDRA_BROADCAST_ADDRESS=${POD_IP:-$HOSTNAME}
-CASSANDRA_BROADCAST_RPC_ADDRESS=${POD_IP:-$HOSTNAME}
-CASSANDRA_DISK_OPTIMIZATION_STRATEGY="${CASSANDRA_DISK_OPTIMIZATION_STRATEGY:-ssd}"
-CASSANDRA_MIGRATION_WAIT="${CASSANDRA_MIGRATION_WAIT:-1}"
-CASSANDRA_ENDPOINT_SNITCH="${CASSANDRA_ENDPOINT_SNITCH:-SimpleSnitch}"
-CASSANDRA_DC="${CASSANDRA_DC}"
-CASSANDRA_RACK="${CASSANDRA_RACK}"
-CASSANDRA_RING_DELAY="${CASSANDRA_RING_DELAY:-30000}"
-CASSANDRA_AUTO_BOOTSTRAP="${CASSANDRA_AUTO_BOOTSTRAP:-true}"
-CASSANDRA_SEEDS="${CASSANDRA_SEEDS:false}"
-CASSANDRA_SEED_PROVIDER="${CASSANDRA_SEED_PROVIDER:-org.apache.cassandra.locator.SimpleSeedProvider}"
-CASSANDRA_AUTO_BOOTSTRAP="${CASSANDRA_AUTO_BOOTSTRAP:false}"
-# Turn off JMX auth
-CASSANDRA_OPEN_JMX="${CASSANDRA_OPEN_JMX:-false}"
-# send GC to STDOUT
-CASSANDRA_GC_STDOUT="${CASSANDRA_GC_STDOUT:-false}"
-echo Starting Cassandra on ${CASSANDRA_LISTEN_ADDRESS}
-echo CASSANDRA_CONF_DIR ${CASSANDRA_CONF_DIR}
-echo CASSANDRA_CFG ${CASSANDRA_CFG}
-echo CASSANDRA_AUTO_BOOTSTRAP ${CASSANDRA_AUTO_BOOTSTRAP}
-echo CASSANDRA_BROADCAST_ADDRESS ${CASSANDRA_BROADCAST_ADDRESS}
-echo CASSANDRA_BROADCAST_RPC_ADDRESS ${CASSANDRA_BROADCAST_RPC_ADDRESS}
-echo CASSANDRA_CLUSTER_NAME ${CASSANDRA_CLUSTER_NAME}
-echo CASSANDRA_COMPACTION_THROUGHPUT_MB_PER_SEC ${CASSANDRA_COMPACTION_THROUGHPUT_MB_PER_SEC}
-echo CASSANDRA_CONCURRENT_COMPACTORS ${CASSANDRA_CONCURRENT_COMPACTORS}
-echo CASSANDRA_CONCURRENT_READS ${CASSANDRA_CONCURRENT_READS}
-echo CASSANDRA_CONCURRENT_WRITES ${CASSANDRA_CONCURRENT_WRITES}
-echo CASSANDRA_COUNTER_CACHE_SIZE_IN_MB ${CASSANDRA_COUNTER_CACHE_SIZE_IN_MB}
-echo CASSANDRA_DC ${CASSANDRA_DC}
-echo CASSANDRA_DISK_OPTIMIZATION_STRATEGY ${CASSANDRA_DISK_OPTIMIZATION_STRATEGY}
-echo CASSANDRA_ENDPOINT_SNITCH ${CASSANDRA_ENDPOINT_SNITCH}
-echo CASSANDRA_GC_WARN_THRESHOLD_IN_MS ${CASSANDRA_GC_WARN_THRESHOLD_IN_MS}
-echo CASSANDRA_INTERNODE_COMPRESSION ${CASSANDRA_INTERNODE_COMPRESSION}
-echo CASSANDRA_KEY_CACHE_SIZE_IN_MB ${CASSANDRA_KEY_CACHE_SIZE_IN_MB}
-echo CASSANDRA_LISTEN_ADDRESS ${CASSANDRA_LISTEN_ADDRESS}
-echo CASSANDRA_LISTEN_INTERFACE ${CASSANDRA_LISTEN_INTERFACE}
-echo CASSANDRA_MEMTABLE_ALLOCATION_TYPE ${CASSANDRA_MEMTABLE_ALLOCATION_TYPE}
-echo CASSANDRA_MEMTABLE_CLEANUP_THRESHOLD ${CASSANDRA_MEMTABLE_CLEANUP_THRESHOLD}
-echo CASSANDRA_MEMTABLE_FLUSH_WRITERS ${CASSANDRA_MEMTABLE_FLUSH_WRITERS}
-echo CASSANDRA_MIGRATION_WAIT ${CASSANDRA_MIGRATION_WAIT}
-echo CASSANDRA_NUM_TOKENS ${CASSANDRA_NUM_TOKENS}
-echo CASSANDRA_RACK ${CASSANDRA_RACK}
-echo CASSANDRA_RING_DELAY ${CASSANDRA_RING_DELAY}
-echo CASSANDRA_RPC_ADDRESS ${CASSANDRA_RPC_ADDRESS}
-echo CASSANDRA_RPC_INTERFACE ${CASSANDRA_RPC_INTERFACE}
-echo CASSANDRA_SEEDS ${CASSANDRA_SEEDS}
-echo CASSANDRA_SEED_PROVIDER ${CASSANDRA_SEED_PROVIDER}
-# if DC and RACK are set, use GossipingPropertyFileSnitch
-if [[ $CASSANDRA_DC && $CASSANDRA_RACK ]]; then
-  echo "dc=$CASSANDRA_DC" > $CASSANDRA_CONF_DIR/cassandra-rackdc.properties
-  echo "rack=$CASSANDRA_RACK" >> $CASSANDRA_CONF_DIR/cassandra-rackdc.properties
-  CASSANDRA_ENDPOINT_SNITCH="GossipingPropertyFileSnitch"
-fi
-if [ -n "$CASSANDRA_MAX_HEAP" ]; then
-  sed -ri "s/^(#)?-Xmx[0-9]+.*/-Xmx$CASSANDRA_MAX_HEAP/" "$CASSANDRA_CONF_DIR/jvm.options"
-  sed -ri "s/^(#)?-Xms[0-9]+.*/-Xms$CASSANDRA_MAX_HEAP/" "$CASSANDRA_CONF_DIR/jvm.options"
-fi
-if [ -n "$CASSANDRA_REPLACE_NODE" ]; then
-   echo "-Dcassandra.replace_address=$CASSANDRA_REPLACE_NODE/" >> "$CASSANDRA_CONF_DIR/jvm.options"
-fi
-for rackdc in dc rack; do
-  var="CASSANDRA_${rackdc^^}"
-  val="${!var}"
-  if [ "$val" ]; then
-	sed -ri 's/^('"$rackdc"'=).*/\1 '"$val"'/' "$CASSANDRA_CONF_DIR/cassandra-rackdc.properties"
-  fi
-done
-# TODO what else needs to be modified
-for yaml in \
-  broadcast_address \
-  broadcast_rpc_address \
-  cluster_name \
-  disk_optimization_strategy \
-  endpoint_snitch \
-  listen_address \
-  num_tokens \
-  rpc_address \
-  start_rpc \
-  key_cache_size_in_mb \
-  concurrent_reads \
-  concurrent_writes \
-  memtable_cleanup_threshold \
-  memtable_allocation_type \
-  memtable_flush_writers \
-  concurrent_compactors \
-  compaction_throughput_mb_per_sec \
-  counter_cache_size_in_mb \
-  internode_compression \
-  endpoint_snitch \
-  gc_warn_threshold_in_ms \
-  listen_interface \
-  rpc_interface \
-  ; do
-  var="CASSANDRA_${yaml^^}"
-  val="${!var}"
-  if [ "$val" ]; then
-    sed -ri 's/^(# )?('"$yaml"':).*/\2 '"$val"'/' "$CASSANDRA_CFG"
-  fi
-done
-echo "auto_bootstrap: ${CASSANDRA_AUTO_BOOTSTRAP}" >> $CASSANDRA_CFG
-# set the seed to itself.  This is only for the first pod, otherwise
-# it will be able to get seeds from the seed provider
-if [[ $CASSANDRA_SEEDS == 'false' ]]; then
-  sed -ri 's/- seeds:.*/- seeds: "'"$POD_IP"'"/' $CASSANDRA_CFG
-else # if we have seeds set them.  Probably StatefulSet
-  sed -ri 's/- seeds:.*/- seeds: "'"$CASSANDRA_SEEDS"'"/' $CASSANDRA_CFG
-fi
-sed -ri 's/- class_name: SEED_PROVIDER/- class_name: '"$CASSANDRA_SEED_PROVIDER"'/' $CASSANDRA_CFG
-# send gc to stdout
-if [[ $CASSANDRA_GC_STDOUT == 'true' ]]; then
-  sed -ri 's/ -Xloggc:\/var\/log\/cassandra\/gc\.log//' $CASSANDRA_CONF_DIR/cassandra-env.sh
-fi
-# enable RMI and JMX to work on one port
-echo "JVM_OPTS=\"\$JVM_OPTS -Djava.rmi.server.hostname=$POD_IP\"" >> $CASSANDRA_CONF_DIR/cassandra-env.sh
-# getting WARNING messages with Migration Service
-echo "-Dcassandra.migration_task_wait_in_seconds=${CASSANDRA_MIGRATION_WAIT}" >> $CASSANDRA_CONF_DIR/jvm.options
-echo "-Dcassandra.ring_delay_ms=${CASSANDRA_RING_DELAY}" >> $CASSANDRA_CONF_DIR/jvm.options
-if [[ $CASSANDRA_OPEN_JMX == 'true' ]]; then
-  export LOCAL_JMX=no
-  sed -ri 's/ -Dcom\.sun\.management\.jmxremote\.authenticate=true/ -Dcom\.sun\.management\.jmxremote\.authenticate=false/' $CASSANDRA_CONF_DIR/cassandra-env.sh
-  sed -ri 's/ -Dcom\.sun\.management\.jmxremote\.password\.file=\/etc\/cassandra\/jmxremote\.password//' $CASSANDRA_CONF_DIR/cassandra-env.sh
-fi
-chmod 700 "${CASSANDRA_DATA}"
-chown -c -R cassandra "${CASSANDRA_DATA}" "${CASSANDRA_CONF_DIR}"
-export CLASSPATH=/kubernetes-cassandra.jar
-su cassandra -c "$CASSANDRA_HOME/bin/cassandra -f"
--- a/examples/storage/cassandra/java/.gitignore
+++ b/examples/storage/cassandra/java/.gitignore
-target
--- a/examples/storage/cassandra/java/README.md
+++ b/examples/storage/cassandra/java/README.md
-This file has moved to [https://github.com/kubernetes/examples/blob/master/staging/storage/cassandra/java/README.md](https://github.com/kubernetes/examples/blob/master/staging/storage/cassandra/java/README.md)
--- a/examples/storage/cassandra/java/pom.xml
+++ b/examples/storage/cassandra/java/pom.xml
-<!--
- Copyright (C) 2015 Google Inc.
- Licensed under the Apache License, Version 2.0 (the "License"); you may not
- use this file except in compliance with the License. You may obtain a copy of
- the License at
- http://www.apache.org/licenses/LICENSE-2.0
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
- WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
- License for the specific language governing permissions and limitations under
- the License.
-->
-<project>
-    <modelVersion>4.0.0</modelVersion>
-    <groupId>io.k8s.cassandra</groupId>
-    <artifactId>kubernetes-cassandra</artifactId>
-    <version>1.0.2</version>
-    <build>
-        <plugins>
-            <plugin>
-                <artifactId>maven-compiler-plugin</artifactId>
-                <version>3.5.1</version>
-                <configuration>
-                    <source>1.8</source>
-                    <target>1.8</target>
-                </configuration>
-            </plugin>
-        </plugins>
-    </build>
-    <properties>
-        <logback.version>1.1.3</logback.version>
-        <cassandra.version>3.9</cassandra.version>
-    </properties>
-    <dependencies>
-        <dependency>
-            <groupId>junit</groupId>
-            <artifactId>junit</artifactId>
-            <version>4.11</version>
-            <scope>test</scope>
-        </dependency>
-        <dependency>
-            <groupId>org.hamcrest</groupId>
-            <artifactId>hamcrest-all</artifactId>
-            <version>1.3</version>
-            <scope>test</scope>
-        </dependency>
-        <dependency>
-            <groupId>org.slf4j</groupId>
-            <artifactId>slf4j-api</artifactId>
-            <version>1.7.5</version>
-            <scope>provided</scope>
-        </dependency>
-        <dependency>
-            <groupId>ch.qos.logback</groupId>
-            <artifactId>logback-classic</artifactId>
-            <version>${logback.version}</version>
-            <scope>provided</scope>
-        </dependency>
-        <dependency>
-            <groupId>ch.qos.logback</groupId>
-            <artifactId>logback-core</artifactId>
-            <version>${logback.version}</version>
-            <scope>provided</scope>
-        </dependency>
-        <dependency>
-            <groupId>org.codehaus.jackson</groupId>
-            <artifactId>jackson-core-asl</artifactId>
-            <version>1.6.3</version>
-            <scope>provided</scope>
-        </dependency>
-        <dependency>
-            <groupId>org.codehaus.jackson</groupId>
-            <artifactId>jackson-mapper-asl</artifactId>
-            <version>1.6.3</version>
-            <scope>provided</scope>
-        </dependency>
-        <dependency>
-            <groupId>org.apache.cassandra</groupId>
-            <artifactId>cassandra-all</artifactId>
-            <version>${cassandra.version}</version>
-            <scope>provided</scope>
-        </dependency>
-    </dependencies>
-</project>
--- a/examples/storage/cassandra/java/src/main/java/io/k8s/cassandra/KubernetesSeedProvider.java
+++ b/examples/storage/cassandra/java/src/main/java/io/k8s/cassandra/KubernetesSeedProvider.java
-/*
- * Copyright (C) 2015 Google Inc.
- *
- * Licensed under the Apache License, Version 2.0 (the "License"); you may not
- * use this file except in compliance with the License. You may obtain a copy of
- * the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
- * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
- * License for the specific language governing permissions and limitations under
- * the License.
- */
-package io.k8s.cassandra;
-import org.apache.cassandra.config.Config;
-import org.apache.cassandra.config.ConfigurationLoader;
-import org.apache.cassandra.config.YamlConfigurationLoader;
-import org.apache.cassandra.exceptions.ConfigurationException;
-import org.apache.cassandra.locator.SeedProvider;
-import org.apache.cassandra.locator.SimpleSeedProvider;
-import org.apache.cassandra.utils.FBUtilities;
-import org.codehaus.jackson.annotate.JsonIgnoreProperties;
-import org.codehaus.jackson.map.ObjectMapper;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import javax.net.ssl.*;
-import java.io.IOException;
-import java.net.InetAddress;
-import java.net.URL;
-import java.net.UnknownHostException;
-import java.nio.file.Files;
-import java.nio.file.Paths;
-import java.security.KeyManagementException;
-import java.security.NoSuchAlgorithmException;
-import java.security.SecureRandom;
-import java.security.cert.X509Certificate;
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.List;
-import java.util.Map;
-/**
- * Self discovery {@link SeedProvider} that creates a list of Cassandra Seeds by
- * communicating with the Kubernetes API.
- * <p>Various System Variable can be used to configure this provider:
- * <ul>
- *     <li>KUBERNETES_PORT_443_TCP_ADDR defaults to kubernetes.default.svc.cluster.local</li>
- *     <li>KUBERNETES_PORT_443_TCP_PORT defaults to 443</li>
- *     <li>CASSANDRA_SERVICE defaults to cassandra</li>
- *     <li>POD_NAMESPACE defaults to 'default'</li>
- *     <li>CASSANDRA_SERVICE_NUM_SEEDS defaults to 8 seeds</li>
- *     <li>K8S_ACCOUNT_TOKEN defaults to the path for the default token</li>
- * </ul>
- */
-public class KubernetesSeedProvider implements SeedProvider {
-    private static final Logger logger = LoggerFactory.getLogger(KubernetesSeedProvider.class);
-    /**
-     * default seeds to fall back on
-     */
-    private List<InetAddress> defaultSeeds;
-    private TrustManager[] trustAll;
-    private HostnameVerifier trustAllHosts;
-    /**
-     * Create new Seeds
-     * @param params
-     */
-    public KubernetesSeedProvider(Map<String, String> params) {
-        // Create default seeds
-        defaultSeeds = createDefaultSeeds();
-        // TODO: Load the CA cert when it is available on all platforms.
-        trustAll = new TrustManager[] {
-            new X509TrustManager() {
-                public void checkServerTrusted(X509Certificate[] certs, String authType) {}
-                public void checkClientTrusted(X509Certificate[] certs, String authType) {}
-                public X509Certificate[] getAcceptedIssuers() { return null; }
-            }
-        };
-        trustAllHosts = new HostnameVerifier() {
-            public boolean verify(String hostname, SSLSession session) {
-                return true;
-            }
-        };
-    }
-    /**
-     * Call kubernetes API to collect a list of seed providers
-     * @return list of seed providers
-     */
-    public List<InetAddress> getSeeds() {
-        String host = getEnvOrDefault("KUBERNETES_PORT_443_TCP_ADDR", "kubernetes.default.svc.cluster.local");
-        String port = getEnvOrDefault("KUBERNETES_PORT_443_TCP_PORT", "443");
-        String serviceName = getEnvOrDefault("CASSANDRA_SERVICE", "cassandra");
-        String podNamespace = getEnvOrDefault("POD_NAMESPACE", "default");
-        String path = String.format("/api/v1/namespaces/%s/endpoints/", podNamespace);
-        String seedSizeVar = getEnvOrDefault("CASSANDRA_SERVICE_NUM_SEEDS", "8");
-        Integer seedSize = Integer.valueOf(seedSizeVar);
-        String accountToken = getEnvOrDefault("K8S_ACCOUNT_TOKEN", "/var/run/secrets/kubernetes.io/serviceaccount/token");
-        List<InetAddress> seeds = new ArrayList<InetAddress>();
-        try {
-            String token = getServiceAccountToken(accountToken);
-            SSLContext ctx = SSLContext.getInstance("SSL");
-            ctx.init(null, trustAll, new SecureRandom());
-            String PROTO = "https://";
-            URL url = new URL(PROTO + host + ":" + port + path + serviceName);
-            logger.info("Getting endpoints from " + url);
-            HttpsURLConnection conn = (HttpsURLConnection)url.openConnection();
-            // TODO: Remove this once the CA cert is propagated everywhere, and replace
-            // with loading the CA cert.
-            conn.setHostnameVerifier(trustAllHosts);
-            conn.setSSLSocketFactory(ctx.getSocketFactory());
-            conn.addRequestProperty("Authorization", "Bearer " + token);
-            ObjectMapper mapper = new ObjectMapper();
-            Endpoints endpoints = mapper.readValue(conn.getInputStream(), Endpoints.class);
-            if (endpoints != null) {
-                // Here is a problem point, endpoints.subsets can be null in first node cases.
-                if (endpoints.subsets != null && !endpoints.subsets.isEmpty()){
-                    for (Subset subset : endpoints.subsets) {
-                        if (subset.addresses != null && !subset.addresses.isEmpty()) {
-                            for (Address address : subset.addresses) {
-                                seeds.add(InetAddress.getByName(address.ip));
-                                if(seeds.size() >= seedSize) {
-                                    logger.info("Available num endpoints: " + seeds.size());
-                                    return Collections.unmodifiableList(seeds);
-                                }
-                            }
-                        }
-                    }
-                }
-                logger.info("Available num endpoints: " + seeds.size());
-            } else {
-                logger.warn("Endpoints are not available using default seeds in cassandra.yaml");
-                return Collections.unmodifiableList(defaultSeeds);
-            }
-        } catch (Exception ex) {
-            logger.warn("Request to kubernetes apiserver failed, using default seeds in cassandra.yaml", ex);
-            return Collections.unmodifiableList(defaultSeeds);
-        }
-        if (seeds.size() == 0) {
-            // If we got nothing, we might be the first instance, in that case
-            // fall back on the seeds that were passed in cassandra.yaml.
-            logger.warn("Seeds are not available using default seeds in cassandra.yaml");
-            return Collections.unmodifiableList(defaultSeeds);
-        }
-        return Collections.unmodifiableList(seeds);
-    }
-    /**
-     * Code taken from {@link SimpleSeedProvider}.  This is used as a fall back
-     * incase we don't find seeds
-     * @return
-     */
-    protected List<InetAddress> createDefaultSeeds()
-    {
-        Config conf;
-        try {
-            conf = loadConfig();
-        }
-        catch (Exception e) {
-            throw new AssertionError(e);
-        }
-        String[] hosts = conf.seed_provider.parameters.get("seeds").split(",", -1);
-        List<InetAddress> seeds = new ArrayList<InetAddress>();
-        for (String host : hosts) {
-            try {
-                seeds.add(InetAddress.getByName(host.trim()));
-            }
-            catch (UnknownHostException ex) {
-                // not fatal... DD will bark if there end up being zero seeds.
-                logger.warn("Seed provider couldn't lookup host {}", host);
-            }
-        }
-        if(seeds.size() == 0) {
-            try {
-                seeds.add(InetAddress.getLocalHost());
-            } catch (UnknownHostException e) {
-                logger.warn("Seed provider couldn't lookup localhost");
-            }
-        }
-        return Collections.unmodifiableList(seeds);
-    }
-    /**
-     * Code taken from {@link SimpleSeedProvider}
-     * @return
-     */
-    protected static Config loadConfig() throws ConfigurationException
-    {
-        String loaderClass = System.getProperty("cassandra.config.loader");
-        ConfigurationLoader loader = loaderClass == null
-                ? new YamlConfigurationLoader()
-                : FBUtilities.<ConfigurationLoader>construct(loaderClass, "configuration loading");
-        return loader.loadConfig();
-    }
-    private static String getEnvOrDefault(String var, String def) {
-        String val = System.getenv(var);
-        if (val == null) {
-            val = def;
-        }
-        return val;
-    }
-    private static String getServiceAccountToken(String file)  {
-        try {
-            return new String(Files.readAllBytes(Paths.get(file)));
-        } catch (IOException e) {
-            logger.warn("unable to load service account token" + file);
-            throw new RuntimeException("Unable to load services account token " + file);
-        }
-    }
-    protected List<InetAddress> getDefaultSeeds() {
-        return defaultSeeds;
-    }
-    @JsonIgnoreProperties(ignoreUnknown = true)
-    static class Address {
-        public String ip;
-    }
-    @JsonIgnoreProperties(ignoreUnknown = true)
-    static class Subset {
-        public List<Address> addresses;
-    }
-    @JsonIgnoreProperties(ignoreUnknown = true)
-    static class Endpoints {
-        public List<Subset> subsets;
-    }
-}
--- a/examples/storage/cassandra/java/src/test/java/io/k8s/cassandra/KubernetesSeedProviderTest.java
+++ b/examples/storage/cassandra/java/src/test/java/io/k8s/cassandra/KubernetesSeedProviderTest.java
-/*
- * Copyright (C) 2015 Google Inc.
- *
- * Licensed under the Apache License, Version 2.0 (the "License"); you may not
- * use this file except in compliance with the License. You may obtain a copy of
- * the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
- * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
- * License for the specific language governing permissions and limitations under
- * the License.
- */
-package io.k8s.cassandra;
-import com.google.common.collect.ImmutableMap;
-import org.apache.cassandra.locator.SeedProvider;
-import org.junit.Ignore;
-import org.junit.Test;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import static org.hamcrest.Matchers.*;
-import java.net.InetAddress;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import static org.junit.Assert.*;
-public class KubernetesSeedProviderTest {
-    private static final Logger logger = LoggerFactory.getLogger(KubernetesSeedProviderTest.class);
-    @Test
-    @Ignore("has to be run inside of a kube cluster")
-    public void getSeeds() throws Exception {
-        SeedProvider provider = new KubernetesSeedProvider(new HashMap<String, String>());
-        List<InetAddress> seeds = provider.getSeeds();
-        assertThat(seeds, is(not(empty())));
-    }
-    @Test
-    public void testDefaultSeeds() throws  Exception {
-        KubernetesSeedProvider provider = new KubernetesSeedProvider(new HashMap<String,String>());
-        List<InetAddress>  seeds = provider.getDefaultSeeds();
-        List<InetAddress> seedsTest = new ArrayList<>();
-        seedsTest.add(InetAddress.getByName("8.4.4.4"));
-        seedsTest.add(InetAddress.getByName("8.8.8.8"));
-        assertThat(seeds, is(not(empty())));
-        assertThat(seeds, is(seedsTest));
-        logger.debug("seeds loaded {}", seeds);
-    }
-}
\ No newline at end of file
--- a/examples/storage/cassandra/java/src/test/resources/cassandra.yaml
+++ b/examples/storage/cassandra/java/src/test/resources/cassandra.yaml
-# Copyright (C) 2015 Google Inc.
-#
-# Licensed under the Apache License, Version 2.0 (the "License"); you may not
-# use this file except in compliance with the License. You may obtain a copy of
-# the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
-# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
-# License for the specific language governing permissions and limitations under
-# the License.
-#
-# Warning!
-# Consider the effects on 'o.a.c.i.s.LegacySSTableTest' before changing schemas in this file.
-#
-cluster_name: Test Cluster
-# memtable_allocation_type: heap_buffers
-memtable_allocation_type: offheap_objects
-commitlog_sync: batch
-commitlog_sync_batch_window_in_ms: 1.0
-commitlog_segment_size_in_mb: 5
-commitlog_directory: target/cassandra/commitlog
-hints_directory: target/cassandra/hints
-partitioner: org.apache.cassandra.dht.ByteOrderedPartitioner
-listen_address: 127.0.0.1
-storage_port: 7010
-rpc_port: 9170
-start_native_transport: true
-native_transport_port: 9042
-column_index_size_in_kb: 4
-saved_caches_directory: target/cassandra/saved_caches
-data_file_directories:
-    - target/cassandra/data
-disk_access_mode: mmap
-seed_provider:
-    - class_name: io.k8s.cassandra.KubernetesSeedProvider 
-      parameters:
-          - seeds: "8.4.4.4,8.8.8.8"
-endpoint_snitch: org.apache.cassandra.locator.SimpleSnitch
-dynamic_snitch: true
-request_scheduler: org.apache.cassandra.scheduler.RoundRobinScheduler
-request_scheduler_id: keyspace
-server_encryption_options:
-    internode_encryption: none
-    keystore: conf/.keystore
-    keystore_password: cassandra
-    truststore: conf/.truststore
-    truststore_password: cassandra
-incremental_backups: true
-concurrent_compactors: 4
-compaction_throughput_mb_per_sec: 0
-row_cache_class_name: org.apache.cassandra.cache.OHCProvider
-row_cache_size_in_mb: 16
-enable_user_defined_functions: true
-enable_scripted_user_defined_functions: true
--- a/examples/storage/cassandra/java/src/test/resources/logback-test.xml
+++ b/examples/storage/cassandra/java/src/test/resources/logback-test.xml
-<!--
- Copyright (C) 2015 Google Inc.
- Licensed under the Apache License, Version 2.0 (the "License"); you may not
- use this file except in compliance with the License. You may obtain a copy of
- the License at
- http://www.apache.org/licenses/LICENSE-2.0
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
- WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
- License for the specific language governing permissions and limitations under
- the License.
-->
-<configuration debug="false" scan="true">
-  <appender name="STDOUT" target="System.out" class="ch.qos.logback.core.ConsoleAppender">
-    <encoder>
-      <pattern>%-5level %date{HH:mm:ss,SSS} %msg%n</pattern>
-    </encoder>
-    <filter class="ch.qos.logback.classic.filter.ThresholdFilter">
-      <level>DEBUG</level>
-    </filter>
-  </appender>
-  <logger name="io.k8s.cassandra" level="DEBUG"/>
-  <root level="INFO">
-    <appender-ref ref="STDOUT" />
-  </root>
-</configuration>
--- a/hack/make-rules/test-cmd-util.sh
+++ b/hack/make-rules/test-cmd-util.sh
@@ -4281,8 +4281,8 @@ run_resource_aliasing_tests() {
  create_and_use_new_namespace
  kube::log::status "Testing resource aliasing"
-  kubectl create -f examples/storage/cassandra/cassandra-controller.yaml "${kube_flags[@]}"
+  kubectl create -f test/e2e/testing-manifests/statefulset/cassandra/controller.yaml "${kube_flags[@]}"
-  kubectl create -f examples/storage/cassandra/cassandra-service.yaml "${kube_flags[@]}"
+  kubectl create -f test/e2e/testing-manifests/statefulset/cassandra/service.yaml "${kube_flags[@]}"
  object="all -l'app=cassandra'"
  request="{{range.items}}{{range .metadata.labels}}{{.}}:{{end}}{{end}}"

--- a/pkg/kubectl/cmd/BUILD
+++ b/pkg/kubectl/cmd/BUILD
@@ -207,6 +207,7 @@ go_test(
        "testdata",
        "//api/openapi-spec:swagger-spec",
        "//examples:config",
+        "//test/e2e/testing-manifests:all-srcs",
        "//test/fixtures",
    ],
    embed = [":go_default_library"],

--- a/pkg/kubectl/cmd/annotate_test.go
+++ b/pkg/kubectl/cmd/annotate_test.go
@@ -535,7 +535,7 @@ func TestAnnotateObjectFromFile(t *testing.T) {
 	cmd := NewCmdAnnotate(tf, buf)
 	cmd.SetOutput(buf)
 	options := &AnnotateOptions{}
-	options.Filenames = []string{"../../../examples/storage/cassandra/cassandra-controller.yaml"}
+	options.Filenames = []string{"../../../test/e2e/testing-manifests/statefulset/cassandra/controller.yaml"}
 	args := []string{"a=b", "c-"}
 	if err := options.Complete(buf, cmd, args); err != nil {
 		t.Fatalf("unexpected error: %v", err)
@@ -564,7 +564,7 @@ func TestAnnotateLocal(t *testing.T) {
 	buf := bytes.NewBuffer([]byte{})
 	cmd := NewCmdAnnotate(tf, buf)
 	options := &AnnotateOptions{local: true}
-	options.Filenames = []string{"../../../examples/storage/cassandra/cassandra-controller.yaml"}
+	options.Filenames = []string{"../../../test/e2e/testing-manifests/statefulset/cassandra/controller.yaml"}
 	args := []string{"a=b"}
 	if err := options.Complete(buf, cmd, args); err != nil {
 		t.Fatalf("unexpected error: %v", err)

--- a/pkg/kubectl/cmd/label_test.go
+++ b/pkg/kubectl/cmd/label_test.go
@@ -387,7 +387,7 @@ func TestLabelForResourceFromFile(t *testing.T) {
 	buf := bytes.NewBuffer([]byte{})
 	cmd := NewCmdLabel(tf, buf)
 	opts := LabelOptions{FilenameOptions: resource.FilenameOptions{
-		Filenames: []string{"../../../examples/storage/cassandra/cassandra-controller.yaml"}}}
+		Filenames: []string{"../../../test/e2e/testing-manifests/statefulset/cassandra/controller.yaml"}}}
 	err := opts.Complete(buf, cmd, []string{"a=b"})
 	if err == nil {
 		err = opts.Validate()
@@ -418,7 +418,7 @@ func TestLabelLocal(t *testing.T) {
 	buf := bytes.NewBuffer([]byte{})
 	cmd := NewCmdLabel(tf, buf)
 	opts := LabelOptions{FilenameOptions: resource.FilenameOptions{
-		Filenames: []string{"../../../examples/storage/cassandra/cassandra-controller.yaml"}},
+		Filenames: []string{"../../../test/e2e/testing-manifests/statefulset/cassandra/controller.yaml"}},
 		local: true}
 	err := opts.Complete(buf, cmd, []string{"a=b"})
 	if err == nil {

--- a/pkg/kubectl/cmd/resource/BUILD
+++ b/pkg/kubectl/cmd/resource/BUILD
@@ -37,6 +37,7 @@ go_test(
    data = [
        "//api/openapi-spec:swagger-spec",
        "//examples:config",
+        "//test/e2e/testing-manifests:all-srcs",
        "//test/fixtures",
    ],
    embed = [":go_default_library"],

--- a/pkg/kubectl/cmd/resource/get_test.go
+++ b/pkg/kubectl/cmd/resource/get_test.go
@@ -401,7 +401,7 @@ func TestGetObjectsFiltered(t *testing.T) {
 		{args: []string{"pods"}, flags: map[string]string{"show-all": "false", "output": "name"}, resp: pods,
 			expect: "pod/foo\npod/bar\n"},
-		{args: []string{}, flags: map[string]string{"show-all": "false", "filename": "../../../../examples/storage/cassandra/cassandra-controller.yaml"}, resp: pods,
+		{args: []string{}, flags: map[string]string{"show-all": "false", "filename": "../../../../test/e2e/testing-manifests/statefulset/cassandra/controller.yaml"}, resp: pods,
 			expect: "NAME      READY     STATUS    RESTARTS   AGE\nfoo       0/0       Failed    0          <unknown>\nbar       0/0                 0          <unknown>\n"},
 		{args: []string{"pods"}, resp: pods, flags: map[string]string{"show-all": "false"},
@@ -556,7 +556,7 @@ func TestGetObjectsIdentifiedByFile(t *testing.T) {
 	cmd := NewCmdGet(tf, buf, errBuf)
 	cmd.SetOutput(buf)
-	cmd.Flags().Set("filename", "../../../../examples/storage/cassandra/cassandra-controller.yaml")
+	cmd.Flags().Set("filename", "../../../../test/e2e/testing-manifests/statefulset/cassandra/controller.yaml")
 	cmd.Run(cmd, []string{})
 	expected := `NAME      READY     STATUS    RESTARTS   AGE
@@ -1265,7 +1265,7 @@ func TestWatchResourceIdentifiedByFile(t *testing.T) {
 	cmd.SetOutput(buf)
 	cmd.Flags().Set("watch", "true")
-	cmd.Flags().Set("filename", "../../../../examples/storage/cassandra/cassandra-controller.yaml")
+	cmd.Flags().Set("filename", "../../../../test/e2e/testing-manifests/statefulset/cassandra/controller.yaml")
 	cmd.Run(cmd, []string{})
 	expected := `NAME      READY     STATUS    RESTARTS   AGE

--- a/pkg/kubectl/cmd/set/BUILD
+++ b/pkg/kubectl/cmd/set/BUILD
@@ -54,6 +54,7 @@ go_test(
    ],
    data = [
        "//examples:config",
+        "//test/e2e/testing-manifests:all-srcs",
        "//test/fixtures",
    ],
    embed = [":go_default_library"],

--- a/pkg/kubectl/cmd/set/set_env_test.go
+++ b/pkg/kubectl/cmd/set/set_env_test.go
@@ -66,7 +66,7 @@ func TestSetEnvLocal(t *testing.T) {
 	cmd.Flags().Set("local", "true")
 	opts := EnvOptions{FilenameOptions: resource.FilenameOptions{
-		Filenames: []string{"../../../../examples/storage/cassandra/cassandra-controller.yaml"}},
+		Filenames: []string{"../../../../test/e2e/testing-manifests/statefulset/cassandra/controller.yaml"}},
 		Out:   buf,
 		Local: true}
 	err := opts.Complete(tf, cmd, []string{"env=prod"})

--- a/pkg/kubectl/cmd/set/set_image_test.go
+++ b/pkg/kubectl/cmd/set/set_image_test.go
@@ -66,7 +66,7 @@ func TestImageLocal(t *testing.T) {
 	cmd.Flags().Set("local", "true")
 	opts := ImageOptions{FilenameOptions: resource.FilenameOptions{
-		Filenames: []string{"../../../../examples/storage/cassandra/cassandra-controller.yaml"}},
+		Filenames: []string{"../../../../test/e2e/testing-manifests/statefulset/cassandra/controller.yaml"}},
 		Out:   buf,
 		Local: true}
 	err := opts.Complete(tf, cmd, []string{"cassandra=thingy"})

--- a/pkg/kubectl/cmd/set/set_resources_test.go
+++ b/pkg/kubectl/cmd/set/set_resources_test.go
@@ -66,7 +66,7 @@ func TestResourcesLocal(t *testing.T) {
 	cmd.Flags().Set("local", "true")
 	opts := ResourcesOptions{FilenameOptions: resource.FilenameOptions{
-		Filenames: []string{"../../../../examples/storage/cassandra/cassandra-controller.yaml"}},
+		Filenames: []string{"../../../../test/e2e/testing-manifests/statefulset/cassandra/controller.yaml"}},
 		Out:               buf,
 		Local:             true,
 		Limits:            "cpu=200m,memory=512Mi",

--- a/pkg/kubectl/cmd/set/set_selector_test.go
+++ b/pkg/kubectl/cmd/set/set_selector_test.go
@@ -334,7 +334,7 @@ func TestSelectorTest(t *testing.T) {
 	cmd.SetOutput(buf)
 	cmd.Flags().Set("output", "name")
 	cmd.Flags().Set("local", "true")
-	cmd.Flags().Set("filename", "../../../../examples/storage/cassandra/cassandra-service.yaml")
+	cmd.Flags().Set("filename", "../../../../test/e2e/testing-manifests/statefulset/cassandra/service.yaml")
 	cmd.Run(cmd, []string{"environment=qa"})

--- a/examples/storage/cassandra/cassandra-controller.yaml
+++ b/examples/storage/cassandra/cassandra-controller.yaml
@@ -38,7 +38,7 @@ spec:
              valueFrom:
                fieldRef:
                  fieldPath: status.podIP
-          image: gcr.io/google-samples/cassandra:v12
+          image: gcr.io/google-samples/cassandra:v13
          name: cassandra
          ports:
            - containerPort: 7000
@@ -55,3 +55,4 @@ spec:
      volumes:
        - name: data
          emptyDir: {}
--- a/test/e2e/testing-manifests/statefulset/cassandra/statefulset.yaml
+++ b/test/e2e/testing-manifests/statefulset/cassandra/statefulset.yaml
@@ -12,7 +12,7 @@ spec:
    spec:
      containers:
      - name: cassandra
-        image: gcr.io/google-samples/cassandra:v12
+        image: gcr.io/google-samples/cassandra:v13
        imagePullPolicy: Always
        ports:
        - containerPort: 7000
@@ -34,7 +34,10 @@ spec:
        lifecycle:
          preStop:
            exec:
-              command: ["/bin/sh", "-c", "PID=$(pidof java) && kill $PID && while ps -p $PID > /dev/null; do sleep 1; done"]
+              command: 
+              - /bin/sh
+              - -c
+              - nodetool drain
        env:
          - name: MAX_HEAP_SIZE
            value: 512M
@@ -52,8 +55,6 @@ spec:
            value: "DC1-K8Demo"
          - name: CASSANDRA_RACK
            value: "Rack1-K8Demo"
-          - name: CASSANDRA_AUTO_BOOTSTRAP
-            value: "false"
          - name: POD_IP
            valueFrom:
              fieldRef: