You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by RAMALINGESWARA RAO THOTTEMPUDI <tr...@iitkgp.ac.in> on 2019/09/18 07:18:06 UTC
Running flink examples
Hi Sir,
I am trying to run the flink programs particularl Pagerank.
I have used the following command :
./bin/flink run -d ./examples/batch/PageRank.jar --input /path/to/input
It is running but it is showing only 15 elements ranking for my data. But I need to find the ranking of all elements of my data.
Because the original program is running only for fixed number of iterations which is 15. How can I modify to run for full data elements.
I have to change the value of fixed number of iterations.
Thanking You,
TR RAO
Re: Running flink examples
Posted by Biao Liu <mm...@gmail.com>.
Hi RAMALINGESWARA,
Are you sure it's reading your input date correctly? Asking this because I
saw the default input date (which is applied if there is no input data
offered) is just 15 elements.
Actually the default number of iterations is 10. You could pass a parameter
"--iterations $the_number_you_wanted" to change the default behavior.
I'm not sure whether it is what you exactly want or not.
You could find the source code of this example here [1]. Maybe it could
help.
1.
https://github.com/apache/flink/blob/master/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/graph/PageRank.java
Thanks,
Biao /'bɪ.aʊ/
On Fri, 20 Sep 2019 at 01:02, RAMALINGESWARA RAO THOTTEMPUDI <
trrao@iitkgp.ac.in> wrote:
> Respected Sir,
>
> It is reading the data but giving only 15 results. for example for
> pagerank only it is giving 15 elements node ranking. But I need each node
> ranking for 20000 nodes.
>
> ------------------------------
> *From: *"Biao Liu" <mm...@gmail.com>
> *To: *"Vijay Bhaskar" <bh...@gmail.com>
> *Cc: *"RAMALINGESWARA RAO THOTTEMPUDI" <tr...@iitkgp.ac.in>, "user" <
> user@flink.apache.org>
> *Sent: *Thursday, September 19, 2019 1:06:53 PM
> *Subject: *Re: Running flink examples
>
> Hi,
> I guess the specific input (--input /path/to/input) didn't work.
> I just checked the PageRank example program, it accepts "--pages" and
> "--links" as input parameters.
>
> Thanks,
> Biao /'bɪ.aʊ/
>
>
>
> On Thu, 19 Sep 2019 at 14:56, Vijay Bhaskar <bh...@gmail.com>
> wrote:
>
>> Can you check whether its able to read the supplied input file properly
>> or not?
>> Regards
>> Bhaskar
>>
>> On Wed, Sep 18, 2019 at 1:07 PM RAMALINGESWARA RAO THOTTEMPUDI <
>> trrao@iitkgp.ac.in> wrote:
>>
>>> Hi Sir,
>>>
>>> I am trying to run the flink programs particularl Pagerank.
>>>
>>> I have used the following command :
>>>
>>> ./bin/flink run -d ./examples/batch/PageRank.jar --input /path/to/input
>>>
>>> It is running but it is showing only 15 elements ranking for my data.
>>> But I need to find the ranking of all elements of my data.
>>> Because the original program is running only for fixed number of
>>> iterations which is 15. How can I modify to run for full data elements.
>>>
>>> I have to change the value of fixed number of iterations.
>>>
>>>
>>>
>>> Thanking You,
>>>
>>> TR RAO
>>>
>>
>
Re: Running flink examples
Posted by Biao Liu <mm...@gmail.com>.
Hi,
I guess the specific input (--input /path/to/input) didn't work.
I just checked the PageRank example program, it accepts "--pages" and
"--links" as input parameters.
Thanks,
Biao /'bɪ.aʊ/
On Thu, 19 Sep 2019 at 14:56, Vijay Bhaskar <bh...@gmail.com>
wrote:
> Can you check whether its able to read the supplied input file properly or
> not?
>
> Regards
> Bhaskar
>
> On Wed, Sep 18, 2019 at 1:07 PM RAMALINGESWARA RAO THOTTEMPUDI <
> trrao@iitkgp.ac.in> wrote:
>
>> Hi Sir,
>>
>> I am trying to run the flink programs particularl Pagerank.
>>
>> I have used the following command :
>>
>> ./bin/flink run -d ./examples/batch/PageRank.jar --input /path/to/input
>>
>> It is running but it is showing only 15 elements ranking for my data. But
>> I need to find the ranking of all elements of my data.
>> Because the original program is running only for fixed number of
>> iterations which is 15. How can I modify to run for full data elements.
>>
>> I have to change the value of fixed number of iterations.
>>
>>
>>
>> Thanking You,
>>
>> TR RAO
>>
>
Re: Running flink examples
Posted by Vijay Bhaskar <bh...@gmail.com>.
Can you check whether its able to read the supplied input file properly or
not?
Regards
Bhaskar
On Wed, Sep 18, 2019 at 1:07 PM RAMALINGESWARA RAO THOTTEMPUDI <
trrao@iitkgp.ac.in> wrote:
> Hi Sir,
>
> I am trying to run the flink programs particularl Pagerank.
>
> I have used the following command :
>
> ./bin/flink run -d ./examples/batch/PageRank.jar --input /path/to/input
>
> It is running but it is showing only 15 elements ranking for my data. But
> I need to find the ranking of all elements of my data.
> Because the original program is running only for fixed number of
> iterations which is 15. How can I modify to run for full data elements.
>
> I have to change the value of fixed number of iterations.
>
>
>
> Thanking You,
>
> TR RAO
>
Re: Running flink examples
Posted by RAMALINGESWARA RAO THOTTEMPUDI <tr...@iitkgp.ac.in>.
Hi Sir,
I am trying to run the flink programs particularl Pagerank.
I have used the following command :
./bin/flink run -d ./examples/batch/PageRank.jar --input /path/to/input
It is running but it is showing only 15 elements ranking for my data. But I need to find the ranking of all elements of my data.
Because the original program is running only for fixed number of iterations which is 15. How can I modify to run for full data elements.
I have to change the value of fixed number of iterations.
Thanking You,
TR RAO
----- Original Message -----
From: "RAMALINGESWARA RAO THOTTEMPUDI" <tr...@iitkgp.ac.in>
To: "user" <us...@flink.apache.org>
Sent: Wednesday, September 18, 2019 12:48:06 PM
Subject: Running flink examples
Hi Sir,
I am trying to run the flink programs particularl Pagerank.
I have used the following command :
./bin/flink run -d ./examples/batch/PageRank.jar --input /path/to/input
It is running but it is showing only 15 elements ranking for my data. But I need to find the ranking of all elements of my data.
Because the original program is running only for fixed number of iterations which is 15. How can I modify to run for full data elements.
I have to change the value of fixed number of iterations.
Thanking You,
TR RAO