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_compatibility.html > > https://ci.apache.org/projects/flink/flink-docs-master/apis/storm_compatibility.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.
