Mailing-List: contact core-user-help@hadoop.apache.org; run by ezmlm
Precedence: bulk
Reply-To: core-user@hadoop.apache.org
Received-SPF: pass (athena.apache.org: local policy)
DomainKey-Signature: a=rsa-sha1; q=dns; c=nofws;
  s=s1024; d=yahoo.com;
  h=X-YMail-OSG:Received:X-Mailer:Date:From:Subject:To:MIME-Version:Content-Type:Message-ID;
  b=0yq1sIcYWFt2rV+/XBmlisHs/vriE3/Zkbv7rXUlCttCcmvhRMznq15LEVThKD3f7FUrUJbgxeh5ZAb+KKMZoHzzOkXFJDdgmAqLFFgQKB2LrbjyG5baLMXNBrDLC7oWKKyyVa/L+g463dHGd85PadyfGJlSnKr8bV0lRD+vD+Y=;
Date: Thu, 16 Oct 2008 13:40:39 -0700 (PDT)
From: Zhengguo 'Mike' SUN <zhengguosun@yahoo.com>
Subject: Any one successfully ran the c++ pipes example?
To: core-user@hadoop.apache.org
MIME-Version: 1.0
Content-Type: multipart/alternative; boundary="0-1587874639-1224189639=:9735"
Message-ID: <543448.9735.qm@web36104.mail.mud.yahoo.com>

--0-1587874639-1224189639=:9735
Content-Type: text/plain; charset=us-ascii

Hi,

I was trying to write an application using the pipes api. But it seemed the serialization part is not working correctly. More specifically, I can't deserialize a string from an StringInStream constructed from context.getInputSplit(). Even with the examples bundled in the distribution archive(wordcount-nopipe.cc), it threw exceptions. If anyone had experience on that, please kindly give some advise.

P.S.
The code that I am suspecting:

HadoopUtils::StringInStream stream(context.getInputSplit());
HadoopUtils::deserializeString(fname, stream);

fname should be deserialized from that stream, but it actually wasn't.


--0-1587874639-1224189639=:9735--