Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id B0629200D42 for ; Fri, 17 Nov 2017 13:22:22 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id AEEF4160BFB; Fri, 17 Nov 2017 12:22:22 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 01E9F160BF8 for ; Fri, 17 Nov 2017 13:22:21 +0100 (CET) Received: (qmail 35883 invoked by uid 500); 17 Nov 2017 12:22:20 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Delivered-To: mailing list user@flink.apache.org Received: (qmail 35873 invoked by uid 99); 17 Nov 2017 12:22:20 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 17 Nov 2017 12:22:20 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd3-us-west.apache.org (ASF Mail Server at spamd3-us-west.apache.org) with ESMTP id 1B5C31808EF for ; Fri, 17 Nov 2017 12:22:20 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -1.8 X-Spam-Level: X-Spam-Status: No, score=-1.8 tagged_above=-999 required=6.31 tests=[KAM_LAZY_DOMAIN_SECURITY=1, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H2=-2.8] autolearn=disabled Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id UqWnPvPkS0Ej for ; Fri, 17 Nov 2017 12:22:19 +0000 (UTC) Received: from smtp113.iad3a.emailsrvr.com (smtp113.iad3a.emailsrvr.com [173.203.187.113]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTPS id F02685F6BE for ; Fri, 17 Nov 2017 12:22:18 +0000 (UTC) Received: from smtp31.relay.iad3a.emailsrvr.com (localhost [127.0.0.1]) by smtp31.relay.iad3a.emailsrvr.com (SMTP Server) with ESMTP id AB7FB249A9 for ; Fri, 17 Nov 2017 07:22:12 -0500 (EST) X-Auth-ID: andre@wegtam.com Received: by smtp31.relay.iad3a.emailsrvr.com (Authenticated sender: andre-AT-wegtam.com) with ESMTPSA id 473712491D for ; Fri, 17 Nov 2017 07:22:12 -0500 (EST) X-Sender-Id: andre@wegtam.com Received: from wotan.wegtam.office (p5B3B398A.dip0.t-ipconnect.de [91.59.57.138]) (using TLSv1.2 with cipher DHE-RSA-AES256-GCM-SHA384) by 0.0.0.0:465 (trex/5.7.12); Fri, 17 Nov 2017 07:22:12 -0500 Date: Fri, 17 Nov 2017 13:22:11 +0100 From: =?ISO-8859-1?Q?Andr=E9_Sch=FCtz?= To: user@flink.apache.org Subject: Accessing Cassandra for reading and writing Message-Id: <20171117132211.0e304a143717be2628beec81@wegtam.com> X-Mailer: Sylpheed 3.5.1 (GTK+ 2.24.30; x86_64-pc-linux-gnu) Mime-Version: 1.0 Content-Type: text/plain; charset=US-ASCII Content-Transfer-Encoding: 7bit archived-at: Fri, 17 Nov 2017 12:22:22 -0000 Hi, we want to read and write from and to Cassandra. We found the Flink-Cassandra connector and added the JAR to the lib folder of the running Flink cluster (local machine). Trying to access the Cassandra database by adding the import to a notebook within Apache Zeppelin, resulted in the following error: import org.apache.flink.streaming.connectors.cassandra._ error: object connectors is not a member of package org.apache.flink.streaming import org.apache.flink.streaming.connectors.cassandra._ We have Flink 1.3.2 running. It would be great to see an example of what to implement for reading from Cassandra and another that uses the Cassandra Connector sink (the example from the documentation gave us the error above). We tried to find something but had no luck. Kind regards, Andre