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 05:42:12 GMT
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" <mxm@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.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_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.


Mime
View raw message