Thanks Max. I was able to get through the compilation error after building it from source.
I am trying to run simple word count topology in Storm and want to compare it with Flink and see how the output is coming out. I am running a simple word count storm topology of read -> split -> count -> print on console The code is present at https://github.com/naveenmadhire/flink-storm-example. When I run the WordCountTopologyFlink.java program, I don¹t see any messages on the console. I modified this class in the same way as it is mentioned in the flink documentation. The detailed job log is at https://gist.github.com/naveenmadhire/be23d54ed14c5e41ab7c When you get some time, can you please check to see why it is not printing anything on the console in local mode. Thanks, Naveen On 12/3/15, 12:11 PM, "Maximilian Michels" <m...@apache.org> wrote: >Hi Naveen, > >I think you're not using the latest 1.0-SNAPSHOT. Did you build from >source? If so, you need to build again because the snapshot API has >been updated recently. > >Best regards, >Max > >On Thu, Dec 3, 2015 at 6:40 PM, Madhire, Naveen ><naveen.madh...@capitalone.com> wrote: >> Hi, >> >> I am trying to execute few storm topologies using Flink, I have a >>question >> related to the documentation, >> >> Can anyone tell me which of the below code is correct, >> >> >>https://ci.apache.org/projects/flink/flink-docs-release-0.10/apis/storm_c >>ompatibility.html >> >> >>https://ci.apache.org/projects/flink/flink-docs-master/apis/storm_compati >>bility.html >> >> >> I want to use Flink-storm 1.0-SNAPSHOT version, I don¹t see any >> createTopology method in FlinkTopology class. >> >> Ex, cluster.submitTopology("WordCount", conf, >> FlinkTopology.createTopology(builder)); >> >> Is the documentation incorrect for the 1.0-SNAPSHOT or may be I missing >> something ;) >> >> Thanks, >> Naveen >> >> ________________________________ >> >> 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.
