flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Maximilian Michels <...@apache.org>
Subject Re: Flink Storm
Date Thu, 03 Dec 2015 18:11:36 GMT
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,

On Thu, Dec 3, 2015 at 6:40 PM, Madhire, Naveen
<Naveen.Madhire@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.

View raw message