From user-return-28873-apmail-cassandra-user-archive=cassandra.apache.org@cassandra.apache.org Tue Sep 18 14:16:54 2012 Return-Path: X-Original-To: apmail-cassandra-user-archive@www.apache.org Delivered-To: apmail-cassandra-user-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 2D025DFA7 for ; Tue, 18 Sep 2012 14:16:54 +0000 (UTC) Received: (qmail 66262 invoked by uid 500); 18 Sep 2012 14:16:51 -0000 Delivered-To: apmail-cassandra-user-archive@cassandra.apache.org Received: (qmail 66232 invoked by uid 500); 18 Sep 2012 14:16:51 -0000 Mailing-List: contact user-help@cassandra.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@cassandra.apache.org Delivered-To: mailing list user@cassandra.apache.org Received: (qmail 66223 invoked by uid 99); 18 Sep 2012 14:16:51 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 18 Sep 2012 14:16:51 +0000 X-ASF-Spam-Status: No, hits=0.0 required=5.0 tests=FSL_RCVD_USER,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of brian.jeltema@digitalenvoy.net designates 64.88.168.16 as permitted sender) Received: from [64.88.168.16] (HELO barracuda.digitalenvoy.net) (64.88.168.16) by apache.org (qpsmtpd/0.29) with SMTP; Tue, 18 Sep 2012 14:16:42 +0000 X-ASG-Debug-ID: 1347977777-459e07ff0001-f7dORa Received: from brian-jeltema.employees.digitalenvoy.net ([64.129.218.66]) by barracuda.digitalenvoy.net with ESMTP id S9w3yvWWCmxk1KRf (version=TLSv1 cipher=AES128-SHA bits=128 verify=NO) for ; Tue, 18 Sep 2012 10:16:17 -0400 (EDT) X-Barracuda-Envelope-From: brian.jeltema@digitalenvoy.net X-Barracuda-Apparent-Source-IP: 64.129.218.66 X-ASG-Whitelist: Client From: Brian Jeltema Content-Type: text/plain; charset=us-ascii Content-Transfer-Encoding: quoted-printable Subject: updating CF from a mapper-only Hadoop job Date: Tue, 18 Sep 2012 10:16:14 -0400 X-ASG-Orig-Subj: updating CF from a mapper-only Hadoop job Message-Id: To: user@cassandra.apache.org Mime-Version: 1.0 (Apple Message framework v1278) X-Mailer: Apple Mail (2.1278) X-Barracuda-Connect: UNKNOWN[64.129.218.66] X-Barracuda-Start-Time: 1347977777 X-Barracuda-Encrypted: AES128-SHA X-Barracuda-URL: http://barracuda.digitalenvoy.net:8000/cgi-mod/mark.cgi X-Virus-Scanned: by bsmtpd at digitalenvoy.net I wrote a Hadoop mapper-only job that uses BulkOutputFormat to load a = Cassandra table. That job would consistently fail with a flurry of exceptions (primary = cause looks like EOFExceptions streaming between nodes). I restructured the job to use an identity mapper and perform the updates = in the reducer. Same code other be moving to the reducer. That job runs correctly. Is this expected behavior? TIA Brian=