Return-Path: X-Original-To: apmail-streams-dev-archive@minotaur.apache.org Delivered-To: apmail-streams-dev-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 2791911718 for ; Wed, 30 Jul 2014 19:05:23 +0000 (UTC) Received: (qmail 96154 invoked by uid 500); 30 Jul 2014 19:05:22 -0000 Delivered-To: apmail-streams-dev-archive@streams.apache.org Received: (qmail 96114 invoked by uid 500); 30 Jul 2014 19:05:22 -0000 Mailing-List: contact dev-help@streams.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@streams.incubator.apache.org Delivered-To: mailing list dev@streams.incubator.apache.org Received: (qmail 96094 invoked by uid 99); 30 Jul 2014 19:05:22 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 30 Jul 2014 19:05:22 +0000 X-ASF-Spam-Status: No, hits=1.7 required=5.0 tests=FREEMAIL_ENVFROM_END_DIGIT,HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of jletourneau80@gmail.com designates 209.85.213.178 as permitted sender) Received: from [209.85.213.178] (HELO mail-ig0-f178.google.com) (209.85.213.178) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 30 Jul 2014 19:05:17 +0000 Received: by mail-ig0-f178.google.com with SMTP id uq10so3483385igb.5 for ; Wed, 30 Jul 2014 12:04:56 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:date:message-id:subject:from:to:content-type; bh=QBv1kVbk3Qo1OngsKKxYdhFMLSdcZG9ShFgw39eFiqA=; b=Z++ErkkFRr5gFsqy8J5YkHYmv83Ic5GKOo6MbLwLOPgoZ1vRSgMRgV/gE/RzMF0cCh F4vo2d5fAIDR8N+TnMpdvFjySsrJX1Og8sesEPLFg5BJxu0uWTEQP3aIVNQSkyOi+K2w XwyI6R23WcxN3L7/vzD/JC5T/tAng0ubofX9WHuYheriSnUhTFljDbTnPxMNoYbYaDj1 FONwQIEehJivdnlQxCoOjeR5TaNkMLm6esEmB7UJWknz3hRNYK6/RNRQse8gCX8M8EKN ojw+I2V5PyQ0UbPfXc3IhPGM6wOiC/J659wYvvWOk3GJr9vpU/Yxw7tDJ01928IDXfLD bHdQ== MIME-Version: 1.0 X-Received: by 10.43.94.73 with SMTP id bx9mr7903195icc.19.1406747096418; Wed, 30 Jul 2014 12:04:56 -0700 (PDT) Received: by 10.64.14.34 with HTTP; Wed, 30 Jul 2014 12:04:56 -0700 (PDT) Date: Wed, 30 Jul 2014 15:04:56 -0400 Message-ID: Subject: ElasticSearch writer From: Jason Letourneau To: "dev@streams.incubator.apache.org" Content-Type: multipart/alternative; boundary=bcaec5186f20f88e5a04ff6dd4b1 X-Virus-Checked: Checked by ClamAV on apache.org --bcaec5186f20f88e5a04ff6dd4b1 Content-Type: text/plain; charset=UTF-8 I am screwing around with the examples (which are awesome btw) and running into a confusing state. Seems like persistent writer is writing successfully, but no attempt at writing to elasticsearch (using the twitter example) is happening. 5:02:24.239 [pool-2-thread-3] DEBUG o.a.s.l.t.StatusCounterMonitorThread - class org.apache.streams.local.tasks.StreamsPersistWriterTask: 0 attempted, 4 success, 0 partial, 0 failed, 4 total 15:02:24.241 [pool-2-thread-2] DEBUG o.a.s.l.t.StatusCounterMonitorThread - class org.apache.streams.elasticsearch.ElasticsearchPersistWriter: 0 attempted, 0 success, 0 partial, 0 failed, 0 total >From what I can tell, ES and Streams seem to be happily connected on startup - any simple thing I am messing up that comes to mind? Jason --bcaec5186f20f88e5a04ff6dd4b1--