Running flink examples

[RAMALINGESWARA RAO THOTTEMPUDI]

 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

[RAMALINGESWARA RAO THOTTEMPUDI]

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" <[hidden email]>
To: "user" <[hidden email]>
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

[Vijay Bhaskar]

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 <[hidden email]> 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

[Biao Liu]

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.

On Thu, 19 Sep 2019 at 14:56, Vijay Bhaskar <[hidden email]> 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 <[hidden email]> 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

[Biao Liu]

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

On Fri, 20 Sep 2019 at 01:02, RAMALINGESWARA RAO THOTTEMPUDI <[hidden email]> 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" <[hidden email]>
To: "Vijay Bhaskar" <[hidden email]>
Cc: "RAMALINGESWARA RAO THOTTEMPUDI" <[hidden email]>, "user" <[hidden email]>
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 <[hidden email]> 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 <[hidden email]> 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