Category : cassandra

This is my docker-compose.yml version: ‘3.7’ services: zookeeper-1: image: confluentinc/cp-zookeeper:latest environment: ZOOKEEPER_CLIENT_PORT: 2181 ZOOKEEPER_TICK_TIME: 2000 ports: – 22181:2181 kafka-1: image: confluentinc/cp-kafka:latest depends_on: – zookeeper-1 ports: – 29092:29092 environment: KAFKA_BROKER_ID: 1 KAFKA_ZOOKEEPER_CONNECT: zookeeper-1:2181 KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka-1:9092,PLAINTEXT_HOST://localhost:29092 KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT KAFKA_INTER_BROKER_LISTENER_NAME: PLAINTEXT KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1 cassandra: image: cassandra container_name: cassandra ports: – 9042:9042 producer: image: spring/producer links: – cassandra depends_on: ..

Read more

Picked up _JAVA_OPTIONS: -Xms128m -Xmx256m [0.013s][warning][gc,ergo] NewSize was set larger than initial heap size, will use initial heap size. [0.013s][warning][gc,ergo] MaxNewSize (409600k) is equal to or greater than the entire heap (262144k). A new max generation size of 262080k will be used. OpenJDK 64-Bit Server VM warning: Option UseConcMarkSweepGC was deprecated in version 9.0 and ..

Read more

I have installed Cassandra in docker along with airflow. I want to insert data in the Cassandra table using airflow. Just like airflow has MySqlOperator to install data in SQL table, so is there any operator or way to insert records into Cassandra table. I found only these two operators: from airflow.providers.apache.cassandra.sensors.record import CassandraRecordSensor from ..

Read more

I want get online data and save to cassandra keyspace. I read this guide, https://phoenixnap.com/kb/install-cassandra-on-windows, to run cassandra. It seems easy, but I get error that related to jdk. So, I tried different way. I tried with docker-toolbox (windows 8.1). I run cassndra by these steps in docker-toolbox shell: $ docker run –name some-cassandra2 –network ..

Read more

I’ve been trying to start a mongoDB and cassandra container and make them pass two simple health checks, but they keep failing no matter what health check I put: For mongoDB, here’s my yml file: version: ‘3.1’ services: mongo: image: mongo:3.6.3 restart: always ports: – 27017:27017 environment: MONGO_INITDB_ROOT_USERNAME: root MONGO_INITDB_ROOT_PASSWORD: ${MONGO_PASSWORD} healthcheck: test: ["CMD", "mongo ..

Read more

I have spark running on one container and cassandra running on another. These are the images i have used for spark – jupyter/all-spark-notebook cassandra – cassandra:latest Scala version in the spark container is 2.12 and spark 3.0.2. I have added the following line in the spark-defaults.conf file spark.jars.packages com.datastax.spark:spark-cassandra-connector_2.12:3.0.2 Both of them are configured on ..

Read more

I want import data from csv to keyspace in cassandra in docker. So I use this command step by step: docker run –name my-cassandra –network some-network -d cassandra:latest docker cp fma_dataset.csv my-cassandra:fma_dataset.csv docker run -it –network some-network –rm cassandra cqlsh my-cassandra CREATE KEYSPACE fma WITH replication = {‘class’: ‘SimpleStrategy’, ‘replication_factor’ : 1}; CREATE TABLE fma_test ..

Read more