s://www.dropbox.com/s/2kcxe59zsi9nrdt/pgpsig.txt>
>> https://www.dropbox.com/s/yxvycjvlsc111bh/pgpsig.txt
>>
>> On Mon, Sep 14, 2015 at 7:40 PM, Ajay Chander > > wrote:
>>
>>> Hi Guys,
>>>
>>> Right now I am trying to implement the same
gt;
> -- PGP PKey --
> <https://www.dropbox.com/s/2kcxe59zsi9nrdt/pgpsig.txt>
> https://www.dropbox.com/s/yxvycjvlsc111bh/pgpsig.txt
>
> On Mon, Sep 14, 2015 at 7:40 PM, Ajay Chander > wrote:
>
>> Hi Guys,
>>
>> Right now I am trying to implement the s
Hi Guys,
Right now I am trying to implement the same as mentioned by Elango in the
below email. I want to perform aggregations based on a time window using
trident. Anyone have done this before using trident? Any help is highly
appreciated.
Thank you,
Ajay
On Thursday, August 27, 2015, Rajasekar
Got it. Thank you Taylor!
On Monday, July 27, 2015, P. Taylor Goetz wrote:
> Yes, you can set the use the “topology.enable.message.timeouts” config
> property:
>
> topology.enable.message.timeouts: false
>
>
> -Taylor
>
> On Jul 27, 2015, at 9:05 AM, Ajay Chande
I guess I found what I needed. I am thinking
"topology.enable.message.timeouts":false is what I am looking for. Thank
you.
On Monday, July 27, 2015, Ajay Chander wrote:
> Any pointers on this ? Thank you!
>
> On Monday, July 27, 2015, Ajay Chander > wrote:
>
>&
Any pointers on this ? Thank you!
On Monday, July 27, 2015, Ajay Chander wrote:
> Hi Everyone,
>
> Is there anyway to explicitly disable replay timeouts specific to the
> topology from my java app?
>
> Thank you,
> Ajay
>
>
Hi Everyone,
Is there anyway to explicitly disable replay timeouts specific to the
topology from my java app?
Thank you,
Ajay
non-primary key
> column, but you have two. Maybe dpci and item were supposed to be the same.
>
> -- Jack Krupansky
>
> On Fri, Jul 10, 2015 at 1:43 AM, Ajay Chander > wrote:
>
> > Any one here came across a situation like this ? Thank you!
> >
> > On Thursday,
Any one here came across a situation like this ? Thank you!
On Thursday, July 9, 2015, Ajay Chander wrote:
> More information:
>
>
> Below is my cassandra bolt.
>
>
> public CassandraTest withCassandraBolt() {
>
> String[] rowKeyFields = {“item","
s/:na]
at com.hmsonline.storm.cassandra.bolt.AbstractBatchingBolt$BatchThread.run(
AbstractBatchingBolt.java:134) [classes/:na]
On Thursday, July 9, 2015, Ajay Chander wrote:
> Hi All,
>
> I am having hard time in writing data into composite columns in
> Cassandra. Any one here used "CompositeRowTupleMapper" from
&g
there any CompositeRowTupleMapperTest.java where I can find how it can
be used.
Any help is highly appreciated.
Thank you,
Ajay
On Thursday, July 9, 2015, Ajay Chander wrote:
> Hi Everyone,
>
> I am using hmsonline/storm-Cassandra from git. I have a table in my
> Cassandra whi
Hi Everyone,
I am using hmsonline/storm-Cassandra from git. I have a table in my
Cassandra which composite keys like ..
Create table testable (itemid varchar, location varchar, price varchar,
type varchar, primary key(itemid, location, price )) with compact storage ;
Now how do I write data into
recipient, please contact
> the sender at the email above and delete this email and any attachments and
> destroy any copies thereof. Any review, retransmission, dissemination,
> copying or other use of, or taking any action in reliance upon, this
> information by persons or entities ot
Any pointers on this? Thank you
On Sunday, June 28, 2015, Ajay Chander wrote:
> Hi Everyone,
>
> I need some help with storm-Cassandra. We have a use case which has, let
> us say product_id and its quantity emitting from one storm bolt.
>
> Public void declareOutputFields(ou
Hi Everyone,
I need some help with storm-Cassandra. We have a use case which has, let us
say product_id and its quantity emitting from one storm bolt.
Public void declareOutputFields(outputFieldsDeclarer declarer){
declarer.declare(new Fields("product_id", "quantity"));}
Now I have created a tab
t made sure the same hdfs-site,
> core-site or hbase-site cluster xml files are available on the class path
> for my topologies on each supervisor node.
>
> Justin
>
> Sent from my iPhone
>
> On Jun 22, 2015, at 8:52 PM, Ajay Chander > wrote:
>
> Thank you Taylor!
t made sure the same hdfs-site,
> core-site or hbase-site cluster xml files are available on the class path
> for my topologies on each supervisor node.
>
> Justin
>
> Sent from my iPhone
>
> On Jun 22, 2015, at 8:52 PM, Ajay Chander > wrote:
>
> Thank you Taylor!
be able to
> connect.
>
> What version of Storm are you using? When you say “trying to write to
> hadoop” do you mean HDFS, or something else? Are you using the storm-hdfs
> component that ships with Apache Storm?
>
> The more details you can provide the better the community
Hi Everyone,
I am trying to write the data into hadoop from my storm topology. For this
communication to happen through hostnames, I have enabled couple of
properties namely "dfs.client.use.datanode.hostname"=true and
"dfs.datanode.use.datanode.hostname" = true in my cloudera manager. Now
how do
19 matches
Mail list logo
