Hi Max, Yeah, I did route the ³count² bolt output to a file and I see the output. I can see the Storm and Flink output matching.
However, I am not able to use the BoltFileSink class in the 1.0-SNAPSHOT which I built. I think it¹s better to wait for a day for the Maven sync to happen so that I can directly use 1.0-SNAPSHOT in the dependency. I have few Storm topologies, which I will try to run on Flink over the next few days. I will let you know how that goes. Thanks :) Thanks, Naveen On 12/4/15, 5:36 AM, "Maximilian Michels" <m...@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.
