flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Madhire, Naveen" <Naveen.Madh...@capitalone.com>
Subject Re: Flink Storm
Date Fri, 04 Dec 2015 19:55:11 GMT
Hi Max,

I forgot to include flink-storm-examples dependency in the application to
use BoltFileSink.

However, the file created by the BoltFileSink is empty. Is there any other
stuff which I need to do to write it into a file by using BoltFileSink?

I am using the same code what you mentioned,

builder.setBolt("file", new BoltFileSink("/tmp/storm", new
OutputFormatter() {
   @Override
   public String format(Tuple tuple) {
      return tuple.toString();
   }
}), 1).shuffleGrouping("count");




Thanks,
Naveen




>
>On 12/4/15, 5:36 AM, "Maximilian Michels" <mxm@apache.org> wrote:
>
>>Hi Naveen,
>>
>>Were you using Maven before? The syncing of changes in the master
>>always takes a while for Maven. The documentation happened to be
>>updated before Maven synchronized. Building and installing manually
>>(what you did) solves the problem.
>>
>>Strangely, when I run your code on my machine with the latest
>>1.0-SNAPSHOT I see a lot of output on my console.
>>
>>Here's the output: https://gist.github.com/mxm/98cd927866b193ce0f89
>>
>>Could you add bolt which writes the Storm tuples to a file? Is that
>>file also empty?
>>
>>builder.setBolt("file", new BoltFileSink("/tmp/storm", new
>>OutputFormatter() {
>>   @Override
>>   public String format(Tuple tuple) {
>>      return tuple.toString();
>>   }
>>}), 1).shuffleGrouping("count");
>>
>>
>>Thanks,
>>Max
>
>________________________________________________________
>
>The information contained in this e-mail is confidential and/or
>proprietary to Capital One and/or its affiliates and may only be used
>solely in performance of work or services for Capital One. The
>information transmitted herewith is intended only for use by the
>individual or entity to which it is addressed. If the reader of this
>message is not the intended recipient, you are hereby notified that any
>review, retransmission, dissemination, distribution, copying or other use
>of, or taking of any action in reliance upon this information is strictly
>prohibited. If you have received this communication in error, please
>contact the sender and delete the material from your computer.
>

________________________________________________________

The information contained in this e-mail is confidential and/or proprietary to Capital One
and/or its affiliates and may only be used solely in performance of work or services for Capital
One. The information transmitted herewith is intended only for use by the individual or entity
to which it is addressed. If the reader of this message is not the intended recipient, you
are hereby notified that any review, retransmission, dissemination, distribution, copying
or other use of, or taking of any action in reliance upon this information is strictly prohibited.
If you have received this communication in error, please contact the sender and delete the
material from your computer.


Mime
View raw message