flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Anirvan BASU <anirvan.b...@inria.fr>
Subject Re: Looking for instructions & source for flink-java-examples-0.7.0-incubating-WebLogAnalysis.jar
Date Wed, 05 Nov 2014 12:52:35 GMT
Hello Fabian, 

Thank you for your prompt reply. 

I did as you explained, this time using the HDFS store instead of our NFS. 

1. I copied all the input files from NFS to HDFS store using the copyFromLocal option. 
As you can see the input files are present in the HDFS store: 
$ hadoop dfs -ls flink/Weblogs 
Found 3 items 
-rw-r--r-- 2 abasu hadoop 21534 2014-11-05 12:09 /user/abasu/flink/Weblogs/documents 
-rw-r--r-- 2 abasu hadoop 1333 2014-11-05 12:09 /user/abasu/flink/Weblogs/ranks 
-rw-r--r-- 2 abasu hadoop 840961 2014-11-05 12:09 /user/abasu/flink/Weblogs/visits 

2. I ran the flink example jar for Weblogs with the following command: 
$ ./flink/bin/flink run flink/examples/flink-java-examples-0.7.0-incubating-WebLogAnalysis.jar hdfs:///user/abasu/flink/Weblogs/documents hdfs:///user/abasu/flink/Weblogs/ranks hdfs:///user/abasu/flink/Weblogs/visits hdfs:///user/abasu/flink/Weblogs/result 

3. Below is part of the output (please scroll down to see the end of my email :-) ) : 
... 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (1/10) switched to SCHEDULED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (1/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (2/10) switched to SCHEDULED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (2/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (3/10) switched to SCHEDULED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (3/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (4/10) switched to SCHEDULED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (4/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (5/10) switched to SCHEDULED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (5/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (6/10) switched to SCHEDULED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (6/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (7/10) switched to SCHEDULED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (7/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (8/10) switched to SCHEDULED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (8/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (9/10) switched to SCHEDULED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (9/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (10/10) switched to SCHEDULED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (10/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (1/10) switched to SCHEDULED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (1/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (2/10) switched to SCHEDULED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (2/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (3/10) switched to SCHEDULED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (3/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (4/10) switched to SCHEDULED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (4/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (5/10) switched to SCHEDULED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (5/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (6/10) switched to SCHEDULED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (6/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (7/10) switched to SCHEDULED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (7/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (8/10) switched to SCHEDULED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (8/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (9/10) switched to SCHEDULED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (9/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (10/10) switched to SCHEDULED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (10/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (1/10) switched to SCHEDULED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (1/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (2/10) switched to SCHEDULED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (2/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (3/10) switched to SCHEDULED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (3/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (4/10) switched to SCHEDULED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (4/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (5/10) switched to SCHEDULED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (5/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (6/10) switched to SCHEDULED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (6/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (7/10) switched to SCHEDULED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (7/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (8/10) switched to SCHEDULED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (8/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (9/10) switched to SCHEDULED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (9/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (10/10) switched to SCHEDULED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (10/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (5/10) switched to RUNNING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (4/10) switched to RUNNING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (1/10) switched to RUNNING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (2/10) switched to RUNNING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (3/10) switched to RUNNING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (6/10) switched to RUNNING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (7/10) switched to RUNNING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (5/10) switched to RUNNING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (6/10) switched to RUNNING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (10/10) switched to RUNNING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (4/10) switched to RUNNING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (9/10) switched to RUNNING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (8/10) switched to RUNNING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (3/10) switched to RUNNING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (7/10) switched to RUNNING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (2/10) switched to RUNNING 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (1/10) switched to SCHEDULED 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (1/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (1/10) switched to RUNNING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (8/10) switched to RUNNING 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (2/10) switched to SCHEDULED 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (2/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (10/10) switched to RUNNING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (5/10) switched to RUNNING 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (1/10) switched to RUNNING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (6/10) switched to RUNNING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (4/10) switched to RUNNING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (2/10) switched to RUNNING 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (5/10) switched to SCHEDULED 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (5/10) switched to DEPLOYING 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (9/10) switched to SCHEDULED 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (9/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (9/10) switched to RUNNING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (3/10) switched to RUNNING 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (3/10) switched to SCHEDULED 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (3/10) switched to DEPLOYING 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (5/10) switched to RUNNING 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (3/10) switched to RUNNING 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (4/10) switched to SCHEDULED 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (4/10) switched to DEPLOYING 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (4/10) switched to RUNNING 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (7/10) switched to SCHEDULED 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (7/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (7/10) switched to RUNNING 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (1/10) switched to SCHEDULED 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (1/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (1/10) switched to RUNNING 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (7/10) switched to RUNNING 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (1/10) switched to RUNNING 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (2/10) switched to SCHEDULED 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (2/10) switched to DEPLOYING 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (2/10) switched to RUNNING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (8/10) switched to RUNNING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (10/10) switched to RUNNING 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (2/10) switched to RUNNING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (9/10) switched to RUNNING 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (9/10) switched to RUNNING 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (3/10) switched to SCHEDULED 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (3/10) switched to DEPLOYING 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (3/10) switched to RUNNING 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (4/10) switched to SCHEDULED 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (4/10) switched to DEPLOYING 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (6/10) switched to SCHEDULED 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (6/10) switched to DEPLOYING 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (4/10) switched to RUNNING 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (10/10) switched to SCHEDULED 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (10/10) switched to DEPLOYING 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (6/10) switched to RUNNING 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (10/10) switched to RUNNING 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (8/10) switched to SCHEDULED 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (8/10) switched to DEPLOYING 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (8/10) switched to RUNNING 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (5/10) switched to SCHEDULED 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (5/10) switched to DEPLOYING 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (5/10) switched to RUNNING 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (6/10) switched to SCHEDULED 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (6/10) switched to DEPLOYING 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (6/10) switched to RUNNING 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (7/10) switched to SCHEDULED 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (7/10) switched to DEPLOYING 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (7/10) switched to RUNNING 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (9/10) switched to SCHEDULED 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (9/10) switched to DEPLOYING 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (8/10) switched to SCHEDULED 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (8/10) switched to DEPLOYING 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (10/10) switched to SCHEDULED 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (10/10) switched to DEPLOYING 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (8/10) switched to RUNNING 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (9/10) switched to RUNNING 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (10/10) switched to RUNNING 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (4/10) switched to SCHEDULED 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (4/10) switched to DEPLOYING 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (7/10) switched to FINISHED 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (2/10) switched to SCHEDULED 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (2/10) switched to FINISHED 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (4/10) switched to FINISHED 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (2/10) switched to DEPLOYING 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (7/10) switched to SCHEDULED 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (1/10) switched to SCHEDULED 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (3/10) switched to SCHEDULED 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (1/10) switched to FINISHED 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (1/10) switched to DEPLOYING 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (3/10) switched to FINISHED 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (3/10) switched to DEPLOYING 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (4/10) switched to RUNNING 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (5/10) switched to SCHEDULED 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (7/10) switched to DEPLOYING 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (5/10) switched to DEPLOYING 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (6/10) switched to SCHEDULED 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (5/10) switched to FINISHED 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (2/10) switched to RUNNING 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (6/10) switched to FINISHED 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (1/10) switched to RUNNING 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (6/10) switched to DEPLOYING 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (3/10) switched to RUNNING 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (7/10) switched to RUNNING 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (5/10) switched to RUNNING 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (6/10) switched to RUNNING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (2/10) switched to FINISHED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (5/10) switched to FINISHED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (1/10) switched to FINISHED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (6/10) switched to FINISHED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (9/10) switched to FINISHED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (7/10) switched to FINISHED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (3/10) switched to FINISHED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (8/10) switched to FINISHED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (4/10) switched to FINISHED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (9/10) switched to FINISHED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (2/10) switched to FINISHED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/documents) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords) -> Map (Projection [0]) (10/10) switched to FINISHED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (3/10) switched to FINISHED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (1/10) switched to FINISHED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (6/10) switched to FINISHED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (5/10) switched to FINISHED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (7/10) switched to FINISHED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (4/10) switched to FINISHED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (8/10) switched to FINISHED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/ranks) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank) (10/10) switched to FINISHED 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (8/10) switched to FINISHED 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (8/10) switched to SCHEDULED 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (8/10) switched to DEPLOYING 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (9/10) switched to FINISHED 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (9/10) switched to SCHEDULED 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (9/10) switched to DEPLOYING 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (10/10) switched to FINISHED 
11/05/2014 11:13:43: Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction) (10/10) switched to FINISHED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (2/10) switched to FINISHED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (5/10) switched to FINISHED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (3/10) switched to FINISHED 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (10/10) switched to SCHEDULED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (1/10) switched to FINISHED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (8/10) switched to FINISHED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (7/10) switched to FINISHED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (4/10) switched to FINISHED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (6/10) switched to FINISHED 
11/05/2014 11:13:43: CHAIN DataSource (CSV Input (|) hdfs:/user/abasu/flink/Weblogs/visits) -> Filter (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate) -> Map (Projection [0]) (9/10) switched to FINISHED 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (10/10) switched to DEPLOYING 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (8/10) switched to RUNNING 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (9/10) switched to RUNNING 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (10/10) switched to RUNNING 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (4/10) switched to FINISHED 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (4/10) switched to FINISHED 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (3/10) switched to FINISHED 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (1/10) switched to FINISHED 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (2/10) switched to FINISHED 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (3/10) switched to FINISHED 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (1/10) switched to FINISHED 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (2/10) switched to FINISHED 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (5/10) switched to FINISHED 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (7/10) switched to FINISHED 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (5/10) switched to FINISHED 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (7/10) switched to FINISHED 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (6/10) switched to FINISHED 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (6/10) switched to FINISHED 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (8/10) switched to FINISHED 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (8/10) switched to FINISHED 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (9/10) switched to FINISHED 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (9/10) switched to FINISHED 
11/05/2014 11:13:43: DataSink(CsvOutputFormat (path: hdfs:/user/abasu/flink/Weblogs/result, delimiter: |)) (10/10) switched to FINISHED 
11/05/2014 11:13:43: CoGroup (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits) (10/10) switched to FINISHED 
11/05/2014 11:13:43: Job execution switched to status FINISHED 

4. However, the files created for each worker output still remain empty: 
$ hadoop dfs -copyToLocal flink/Weblogs/result examples/Weblogs/ 
$ ls -al examples/Weblogs/result/ 
total 8 
drwxr-xr-x 2 abasu users 4096 Nov 5 13:49 . 
drwxr-xr-x 3 abasu users 4096 Nov 5 13:49 .. 
-rw-r--r-- 1 abasu users 0 Nov 5 13:49 1 
-rw-r--r-- 1 abasu users 0 Nov 5 13:49 10 
-rw-r--r-- 1 abasu users 0 Nov 5 13:49 2 
-rw-r--r-- 1 abasu users 0 Nov 5 13:49 3 
-rw-r--r-- 1 abasu users 0 Nov 5 13:49 4 
-rw-r--r-- 1 abasu users 0 Nov 5 13:49 5 
-rw-r--r-- 1 abasu users 0 Nov 5 13:49 6 
-rw-r--r-- 1 abasu users 0 Nov 5 13:49 7 
-rw-r--r-- 1 abasu users 0 Nov 5 13:49 8 
-rw-r--r-- 1 abasu users 0 Nov 5 13:49 9 

$ cat examples/Weblogs/result/1 
$ 

So I'm wondering what I am missing ... ? 

Thanks in advance for all your help and suggestions. 
Anirvan 

----- Original Message -----

> From: "Fabian Hueske" <fhueske@apache.org>
> To: user@flink.incubator.apache.org
> Sent: Tuesday, November 4, 2014 4:28:40 PM
> Subject: Re: Looking for instructions & source for
> flink-java-examples-0.7.0-incubating-WebLogAnalysis.jar

> Hi Anirvan,

> you specify input and output as files in the local file system (file:///).
> Each worker needs access to the all input files, which means that each
> worker needs (a copy of) these files in its local file system.
> The common setup to use Flink in a distributed cluster is to use a
> distributed data store such as HDFS (or a data store that can be accessed by
> each node).
> Using a shared file system (like NFS) that is mounted into each worker would
> work, but remember, that all nodes will concurrently read and write to the
> shared system.

> Have you checked the local file systems on all workers for output?
> Did the job process any data at all? The jobs finishes within 1 second (which
> is still possible for very small input data).

> You can change the example program to write its output to the stdout by
> replacing the writeAsCSV() by print(). The stdout of all workers is
> redirected to the ./log/*.out files.

> Best, Fabian

> 2014-11-04 16:08 GMT+01:00 Anirvan BASU < anirvan.basu@inria.fr > :

> > Hello Robert, Stephan et al,
> 

> > Hope you are doing fine in Berlin.
> 

> > I am getting back to you on my previous problem on the WebLogAnalysis
> > example, after a long time.
> 

> > We are currently using Flink 0.7.0 over a 10-node cluster in Manager-Worker
> > configuration.
> 

> > We ran the following command:
> 
> > $ ./flink/bin/flink run
> > flink/examples/flink-java-examples-0.7.0-incubating-WebLogAnalysis.jar
> > file:///home/abasu/examples/Weblogs/documents
> > file:///home/abasu/examples/Weblogs/ranks
> > file:///home/abasu/examples/Weblogs/visits
> > file:///home/abasu/examples/Weblogs/result
> 

> > For the documents, rank and visits files, we used the data generated by you
> > from this link:
> 
> > https://github.com/rmetzger/scratch/tree/weblogdataexample/weblog
> 

> > The program executed with the following output:
> 
> > 11/04/2014 14:58:12: Job execution switched to status RUNNING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (1/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (1/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (2/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (2/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (3/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (3/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (4/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (4/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (5/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (5/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (6/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (6/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (7/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (7/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (8/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (8/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (9/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (9/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (1/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (1/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (2/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (2/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (3/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (3/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (4/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (4/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (5/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (5/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (6/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (6/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (7/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (7/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (8/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (8/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (9/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (9/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (1/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (1/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (2/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (2/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (3/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (3/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (4/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (4/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (5/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (5/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (6/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (1/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (6/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (7/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (7/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (8/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (8/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (9/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (9/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (2/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (5/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (6/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (7/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (8/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (2/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (9/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (5/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (6/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (8/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (7/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (3/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (9/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (1/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (1/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (2/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (2/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (8/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (2/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (3/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (2/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (3/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (3/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (1/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (1/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (1/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (3/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (1/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (4/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (1/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (4/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (5/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (6/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (4/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (7/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (9/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (3/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (1/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (4/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (4/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (6/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (6/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (5/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (5/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (6/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (5/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (2/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (2/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (4/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (2/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (7/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (7/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (8/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (8/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (7/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (3/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (3/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (8/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (9/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (9/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (3/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (9/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (4/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (4/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (4/9) switched to RUNNING
> 
> > 11/04/2014 14:58:12: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (5/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:12: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (5/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:12: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (5/9) switched to RUNNING
> 
> > 11/04/2014 14:58:13: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (6/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:13: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (6/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:13: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (6/9) switched to RUNNING
> 
> > 11/04/2014 14:58:13: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (7/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:13: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (7/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:13: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (7/9) switched to RUNNING
> 
> > 11/04/2014 14:58:13: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (8/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:13: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (8/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:13: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (8/9) switched to RUNNING
> 
> > 11/04/2014 14:58:13: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (9/9) switched to SCHEDULED
> 
> > 11/04/2014 14:58:13: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (9/9) switched to DEPLOYING
> 
> > 11/04/2014 14:58:13: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (9/9) switched to RUNNING
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (7/9) switched to
> > SCHEDULED
> 
> > 11/04/2014 14:58:13:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (7/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (7/9) switched to
> > DEPLOYING
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (8/9) switched to
> > SCHEDULED
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (8/9) switched to
> > DEPLOYING
> 
> > 11/04/2014 14:58:13:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (8/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (5/9) switched to
> > SCHEDULED
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (5/9) switched to
> > DEPLOYING
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (6/9) switched to
> > SCHEDULED
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (6/9) switched to
> > DEPLOYING
> 
> > 11/04/2014 14:58:13:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (5/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (4/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (6/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (4/9) switched to
> > SCHEDULED
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (7/9) switched to
> > RUNNING
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (4/9) switched to
> > DEPLOYING
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (3/9) switched to
> > SCHEDULED
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (3/9) switched to
> > DEPLOYING
> 
> > 11/04/2014 14:58:13:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (3/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (2/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (2/9) switched to
> > SCHEDULED
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (2/9) switched to
> > DEPLOYING
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (1/9) switched to
> > SCHEDULED
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (1/9) switched to
> > DEPLOYING
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (5/9) switched to
> > RUNNING
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (4/9) switched to
> > RUNNING
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (3/9) switched to
> > RUNNING
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (2/9) switched to
> > RUNNING
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (8/9) switched to
> > RUNNING
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (6/9) switched to
> > RUNNING
> 
> > 11/04/2014 14:58:13:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (1/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (1/9) switched to
> > RUNNING
> 
> > 11/04/2014 14:58:13: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (4/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (2/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (5/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (9/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (4/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (8/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (6/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (2/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (5/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (7/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (9/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (6/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (7/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (8/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13:
> > Join(org.apache.flink.api.java.operators.JoinOperator$ProjectFlatJoinFunction)
> > (9/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (9/9) switched to
> > SCHEDULED
> 
> > 11/04/2014 14:58:13: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (9/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (9/9) switched to
> > DEPLOYING
> 
> > 11/04/2014 14:58:13: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (4/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (2/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (7/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (6/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (5/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (8/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (1/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/documents) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterDocByKeyWords)
> > -> Map (Projection [0]) (3/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (1/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (1/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/visits) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterVisitsByDate)
> > -> Map (Projection [0]) (3/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: CHAIN DataSource (CSV Input (|)
> > file:/home/abasu/examples/Weblogs/ranks) -> Filter
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$FilterByRank)
> > (3/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (9/9) switched to
> > RUNNING
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (7/9) switched to
> > FINISHED
> 
> > 11/04/2014 14:58:13: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (7/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (8/9) switched to
> > FINISHED
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (5/9) switched to
> > FINISHED
> 
> > 11/04/2014 14:58:13: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (8/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (6/9) switched to
> > FINISHED
> 
> > 11/04/2014 14:58:13: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (5/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (6/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (4/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (4/9) switched to
> > FINISHED
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (1/9) switched to
> > FINISHED
> 
> > 11/04/2014 14:58:13: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (1/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (3/9) switched to
> > FINISHED
> 
> > 11/04/2014 14:58:13: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (3/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (2/9) switched to
> > FINISHED
> 
> > 11/04/2014 14:58:13: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (2/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: DataSink(CsvOutputFormat (path:
> > file:/home/abasu/examples/Weblogs/result, delimiter: |)) (9/9) switched to
> > FINISHED
> 
> > 11/04/2014 14:58:13: CoGroup
> > (org.apache.flink.examples.java.relational.WebLogAnalysis$AntiJoinVisits)
> > (9/9) switched to FINISHED
> 
> > 11/04/2014 14:58:13: Job execution switched to status FINISHED
> 

> > The following directory was created:
> 
> > /home/abasu/examples/Weblogs/result
> 
> > with 9 files (named 1 to 9)
> 
> > All these files are empty!
> 

> > Hence my naive question: Is this the expected output ? Or what should be
> > the
> > expected output for an error-free run ?
> 

> > Please let me know where we are going wrong?
> 
> > If possible do you have other data generated to try the WebLogAnalysis
> > example ?
> 

> > Thanks in advance for your advice and help,
> 
> > Anirvan
> 

> > > > > > > > > > > Le 23/09/2014 17:22, rmetzger0 [via Apache Flink
> > > > > > > > > > > (Incubator)
> > > > > > > > > > > User
> > > > > > > > > > > Mailing
> > > > > > > > > > > List archive.] a écrit :
> > > > > > > > > > 
> > > > > > > > > 
> > > > > > > > 
> > > > > > > 
> > > > > > 
> > > > > 
> > > > 
> > > 
> > 
> 

> > > > > > > > > > > > Hi,
> > > > > > > > > > > 
> > > > > > > > > > 
> > > > > > > > > 
> > > > > > > > 
> > > > > > > 
> > > > > > 
> > > > > 
> > > > 
> > > 
> > 
> 

> > > > > > > > > > > > you have to use the "WebLogDataGenerator" found here:
> > > > > > > > > > > > https://github.com/apache/incubator-flink/blob/master/flink-examples/flink-java-examples/src/main/java/org/apache/flink/examples/java/relational/util/WebLogDataGenerator.java
> > > > > > > > > > > 
> > > > > > > > > > 
> > > > > > > > > 
> > > > > > > > 
> > > > > > > 
> > > > > > 
> > > > > 
> > > > 
> > > 
> > 
> 

> > > > > > > > > > > > It accepts two arguments, the number of documents and
> > > > > > > > > > > > visits.
> > > > > > > > > > > 
> > > > > > > > > > 
> > > > > > > > > 
> > > > > > > > 
> > > > > > > 
> > > > > > 
> > > > > 
> > > > 
> > > 
> > 
> 
> > > > > > > > > > > > The generated files are located in /tmp/documents
> > > > > > > > > > > > /tmp/ranks
> > > > > > > > > > > > and
> > > > > > > > > > > > /tmp/visits.
> > > > > > > > > > > 
> > > > > > > > > > 
> > > > > > > > > 
> > > > > > > > 
> > > > > > > 
> > > > > > 
> > > > > 
> > > > 
> > > 
> > 
> 
> > > > > > > > > > > > I've generated some sample data for you, located here:
> > > > > > > > > > > > https://github.com/rmetzger/scratch/tree/weblogdataexample/weblog
> > > > > > > > > > > 
> > > > > > > > > > 
> > > > > > > > > 
> > > > > > > > 
> > > > > > > 
> > > > > > 
> > > > > 
> > > > 
> > > 
> > 
> 

> > > > > > > > > > > > Best,
> > > > > > > > > > > 
> > > > > > > > > > 
> > > > > > > > > 
> > > > > > > > 
> > > > > > > 
> > > > > > 
> > > > > 
> > > > 
> > > 
> > 
> 
> > > > > > > > > > > > Robert
> > > > > > > > > > > 
> > > > > > > > > > 
> > > > > > > > > 
> > > > > > > > 
> > > > > > > 
> > > > > > 
> > > > > 
> > > > 
> > > 
> > 
> 

> > > > > > > > > > > > On Tue, Sep 23, 2014 at 4:05 PM, nirvanesque [via
> > > > > > > > > > > > Apache
> > > > > > > > > > > > Flink
> > > > > > > > > > > > (Incubator)
> > > > > > > > > > > > User Mailing List archive.] < [hidden email] > wrote:
> > > > > > > > > > > 
> > > > > > > > > > 
> > > > > > > > > 
> > > > > > > > 
> > > > > > > 
> > > > > > 
> > > > > 
> > > > 
> > > 
> > 
> 

> > > > > > > > > > > > > Hello Robert,
> > > > > > > > > > > > 
> > > > > > > > > > > 
> > > > > > > > > > 
> > > > > > > > > 
> > > > > > > > 
> > > > > > > 
> > > > > > 
> > > > > 
> > > > 
> > > 
> > 
> 

> > > > > > > > > > > > > Thanks as usual for all your help with the
> > > > > > > > > > > > > information.
> > > > > > > > > > > > 
> > > > > > > > > > > 
> > > > > > > > > > 
> > > > > > > > > 
> > > > > > > > 
> > > > > > > 
> > > > > > 
> > > > > 
> > > > 
> > > 
> > 
> 

> > > > > > > > > > > > > I'm trying in vain to create the different input
> > > > > > > > > > > > > files
> > > > > > > > > > > > > from
> > > > > > > > > > > > > the
> > > > > > > > > > > > > program
> > > > > > > > > > > > > source code but running into difficulties.
> > > > > > > > > > > > 
> > > > > > > > > > > 
> > > > > > > > > > 
> > > > > > > > > 
> > > > > > > > 
> > > > > > > 
> > > > > > 
> > > > > 
> > > > 
> > > 
> > 
> 

> > > > > > > > > > > > > Could you (or anyone else) please post here samples
> > > > > > > > > > > > > of
> > > > > > > > > > > > > the
> > > > > > > > > > > > > 4
> > > > > > > > > > > > > inputs
> > > > > > > > > > > > > that
> > > > > > > > > > > > > are
> > > > > > > > > > > > > required to run this program ?
> > > > > > > > > > > > 
> > > > > > > > > > > 
> > > > > > > > > > 
> > > > > > > > > 
> > > > > > > > 
> > > > > > > 
> > > > > > 
> > > > > 
> > > > 
> > > 
> > 
> 

> > > > > > > > > > > > > Thanks in advance,
> > > > > > > > > > > > 
> > > > > > > > > > > 
> > > > > > > > > > 
> > > > > > > > > 
> > > > > > > > 
> > > > > > > 
> > > > > > 
> > > > > 
> > > > 
> > > 
> > 
> 
> > > > > > > > > > > > > Anirvan
> > > > > > > > > > > > 
> > > > > > > > > > > 
> > > > > > > > > > 
> > > > > > > > > 
> > > > > > > > 
> > > > > > > 
> > > > > > 
> > > > > 
> > > > 
> > > 
> > 
> 

> > > > > > > > > > > > > Le 09/09/2014 23:54, rmetzger0 [via Apache Flink
> > > > > > > > > > > > > (Incubator)
> > > > > > > > > > > > > User
> > > > > > > > > > > > > Mailing
> > > > > > > > > > > > > List archive.] a écrit :
> > > > > > > > > > > > 
> > > > > > > > > > > 
> > > > > > > > > > 
> > > > > > > > > 
> > > > > > > > 
> > > > > > > 
> > > > > > 
> > > > > 
> > > > 
> > > 
> > 
> 

> > > > > > > > > > > > > > Hi Anirvan,
> > > > > > > > > > > > > 
> > > > > > > > > > > > 
> > > > > > > > > > > 
> > > > > > > > > > 
> > > > > > > > > 
> > > > > > > > 
> > > > > > > 
> > > > > > 
> > > > > 
> > > > 
> > > 
> > 
> 

> > > > > > > > > > > > > > sorry for the late response. You've posted the
> > > > > > > > > > > > > > question
> > > > > > > > > > > > > > to
> > > > > > > > > > > > > > Nabble,
> > > > > > > > > > > > > > which
> > > > > > > > > > > > > > is
> > > > > > > > > > > > > > only a mirror of our actual mailing list at [hidden
> > > > > > > > > > > > > > email]
> > > > > > > > > > > > > > .
> > > > > > > > > > > > > > Sadly,
> > > > > > > > > > > > > > the
> > > > > > > > > > > > > > message is not automatically posted to the apache
> > > > > > > > > > > > > > list
> > > > > > > > > > > > > > because
> > > > > > > > > > > > > > the
> > > > > > > > > > > > > > apache
> > > > > > > > > > > > > > server is rejecting the mails from nabble.
> > > > > > > > > > > > > 
> > > > > > > > > > > > 
> > > > > > > > > > > 
> > > > > > > > > > 
> > > > > > > > > 
> > > > > > > > 
> > > > > > > 
> > > > > > 
> > > > > 
> > > > 
> > > 
> > 
> 
> > > > > > > > > > > > > > I've already asked and there is no way to change
> > > > > > > > > > > > > > this
> > > > > > > > > > > > > > behavior.
> > > > > > > > > > > > > 
> > > > > > > > > > > > 
> > > > > > > > > > > 
> > > > > > > > > > 
> > > > > > > > > 
> > > > > > > > 
> > > > > > > 
> > > > > > 
> > > > > 
> > > > 
> > > 
> > 
> 
> > > > > > > > > > > > > > So I actually saw the two messages you posted here
> > > > > > > > > > > > > > by
> > > > > > > > > > > > > > accident.
> > > > > > > > > > > > > 
> > > > > > > > > > > > 
> > > > > > > > > > > 
> > > > > > > > > > 
> > > > > > > > > 
> > > > > > > > 
> > > > > > > 
> > > > > > 
> > > > > 
> > > > 
> > > 
> > 
> 

> > > > > > > > > > > > > > Regarding your actual question:
> > > > > > > > > > > > > 
> > > > > > > > > > > > 
> > > > > > > > > > > 
> > > > > > > > > > 
> > > > > > > > > 
> > > > > > > > 
> > > > > > > 
> > > > > > 
> > > > > 
> > > > 
> > > 
> > 
> 
> > > > > > > > > > > > > > - The command line arguments for the WebLogAnalysis
> > > > > > > > > > > > > > example
> > > > > > > > > > > > > > are:
> > > > > > > > > > > > > 
> > > > > > > > > > > > 
> > > > > > > > > > > 
> > > > > > > > > > 
> > > > > > > > > 
> > > > > > > > 
> > > > > > > 
> > > > > > 
> > > > > 
> > > > 
> > > 
> > 
> 
> > > > > > > > > > > > > > "WebLogAnalysis <documents path> <ranks path>
> > > > > > > > > > > > > > <visits
> > > > > > > > > > > > > > path>
> > > > > > > > > > > > > > <result
> > > > > > > > > > > > > > path>"
> > > > > > > > > > > > > 
> > > > > > > > > > > > 
> > > > > > > > > > > 
> > > > > > > > > > 
> > > > > > > > > 
> > > > > > > > 
> > > > > > > 
> > > > > > 
> > > > > 
> > > > 
> > > 
> > 
> 

> > > > > > > > > > > > > > - Regarding the "info -d" command. I think its an
> > > > > > > > > > > > > > artifact
> > > > > > > > > > > > > > from
> > > > > > > > > > > > > > our
> > > > > > > > > > > > > > old
> > > > > > > > > > > > > > java
> > > > > > > > > > > > > > API. I've filed an issue in JIRA:
> > > > > > > > > > > > > > https://issues.apache.org/jira/browse/FLINK-1095
> > > > > > > > > > > > > > Lets
> > > > > > > > > > > > > > see
> > > > > > > > > > > > > > how
> > > > > > > > > > > > > > we
> > > > > > > > > > > > > > resolve
> > > > > > > > > > > > > > it.
> > > > > > > > > > > > > > Thanks for reporting this!
> > > > > > > > > > > > > 
> > > > > > > > > > > > 
> > > > > > > > > > > 
> > > > > > > > > > 
> > > > > > > > > 
> > > > > > > > 
> > > > > > > 
> > > > > > 
> > > > > 
> > > > 
> > > 
> > 
> 

> > > > > > > > > > > > > > You can find the source code of all of our examples
> > > > > > > > > > > > > > in
> > > > > > > > > > > > > > the
> > > > > > > > > > > > > > source
> > > > > > > > > > > > > > release
> > > > > > > > > > > > > > of
> > > > > > > > > > > > > > Flink (in the flink-examples/flink-java-examples
> > > > > > > > > > > > > > project.
> > > > > > > > > > > > > > You
> > > > > > > > > > > > > > can
> > > > > > > > > > > > > > also
> > > > > > > > > > > > > > access the source (and hence the examples) through
> > > > > > > > > > > > > > GitHub:
> > > > > > > > > > > > > > https://github.com/apache/incubator-flink/blob/master/flink-examples/flink-java-examples/src/main/java/org/apache/flink/example/java/relational/WebLogAnalysis.java
> > > > > > > > > > > > > > .
> > > > > > > > > > > > > 
> > > > > > > > > > > > 
> > > > > > > > > > > 
> > > > > > > > > > 
> > > > > > > > > 
> > > > > > > > 
> > > > > > > 
> > > > > > 
> > > > > 
> > > > 
> > > 
> > 
> 

> > > > > > > > > > > > > > To build the examples, you can run: "mvn clean
> > > > > > > > > > > > > > package
> > > > > > > > > > > > > > -DskipTests"
> > > > > > > > > > > > > > in
> > > > > > > > > > > > > > the
> > > > > > > > > > > > > > "flink-examples/flink-java-examples" directory.
> > > > > > > > > > > > > > This
> > > > > > > > > > > > > > will
> > > > > > > > > > > > > > re-build
> > > > > > > > > > > > > > them.
> > > > > > > > > > > > > 
> > > > > > > > > > > > 
> > > > > > > > > > > 
> > > > > > > > > > 
> > > > > > > > > 
> > > > > > > > 
> > > > > > > 
> > > > > > 
> > > > > 
> > > > 
> > > 
> > 
> 

> > > > > > > > > > > > > > If you don't want to import the whole Flink project
> > > > > > > > > > > > > > just
> > > > > > > > > > > > > > for
> > > > > > > > > > > > > > playing
> > > > > > > > > > > > > > around
> > > > > > > > > > > > > > with the examples, you can also create an empty
> > > > > > > > > > > > > > maven
> > > > > > > > > > > > > > project.
> > > > > > > > > > > > > > This
> > > > > > > > > > > > > > script:
> > > > > > > > > > > > > 
> > > > > > > > > > > > 
> > > > > > > > > > > 
> > > > > > > > > > 
> > > > > > > > > 
> > > > > > > > 
> > > > > > > 
> > > > > > 
> > > > > 
> > > > 
> > > 
> > 
> 
> > > > > > > > > > > > > > curl
> > > > > > > > > > > > > > https://raw.githubusercontent.com/apache/incubator-flink/master/flink-quickstart/quickstart.sh
> > > > > > > > > > > > > > | bash
> > > > > > > > > > > > > 
> > > > > > > > > > > > 
> > > > > > > > > > > 
> > > > > > > > > > 
> > > > > > > > > 
> > > > > > > > 
> > > > > > > 
> > > > > > 
> > > > > 
> > > > 
> > > 
> > 
> 

> > > > > > > > > > > > > > will automatically set everything up for you. Just
> > > > > > > > > > > > > > import
> > > > > > > > > > > > > > the
> > > > > > > > > > > > > > "quickstart"
> > > > > > > > > > > > > > project into Eclipse or IntelliJ. It will download
> > > > > > > > > > > > > > all
> > > > > > > > > > > > > > dependencies
> > > > > > > > > > > > > > and
> > > > > > > > > > > > > > package everything correctly. If you want to use an
> > > > > > > > > > > > > > example
> > > > > > > > > > > > > > there,
> > > > > > > > > > > > > > just
> > > > > > > > > > > > > > copy
> > > > > > > > > > > > > > the Java file into the "quickstart" project.
> > > > > > > > > > > > > 
> > > > > > > > > > > > 
> > > > > > > > > > > 
> > > > > > > > > > 
> > > > > > > > > 
> > > > > > > > 
> > > > > > > 
> > > > > > 
> > > > > 
> > > > 
> > > 
> > 
> 

> > > > > > > > > > > > > > The examples are indeed a very good way to learn
> > > > > > > > > > > > > > how
> > > > > > > > > > > > > > to
> > > > > > > > > > > > > > write
> > > > > > > > > > > > > > Flink
> > > > > > > > > > > > > > jobs.
> > > > > > > > > > > > > 
> > > > > > > > > > > > 
> > > > > > > > > > > 
> > > > > > > > > > 
> > > > > > > > > 
> > > > > > > > 
> > > > > > > 
> > > > > > 
> > > > > 
> > > > 
> > > 
> > 
> 

> > > > > > > > > > > > > > Please continue asking if you have further
> > > > > > > > > > > > > > questions!
> > > > > > > > > > > > > 
> > > > > > > > > > > > 
> > > > > > > > > > > 
> > > > > > > > > > 
> > > > > > > > > 
> > > > > > > > 
> > > > > > > 
> > > > > > 
> > > > > 
> > > > 
> > > 
> > 
> 

> > > > > > > > > > > > > > Best,
> > > > > > > > > > > > > 
> > > > > > > > > > > > 
> > > > > > > > > > > 
> > > > > > > > > > 
> > > > > > > > > 
> > > > > > > > 
> > > > > > > 
> > > > > > 
> > > > > 
> > > > 
> > > 
> > 
> 
> > > > > > > > > > > > > > Robert
> > > > > > > > > > > > > 
> > > > > > > > > > > > 
> > > > > > > > > > > 
> > > > > > > > > > 
> > > > > > > > > 
> > > > > > > > 
> > > > > > > 
> > > > > > 
> > > > > 
> > > > 
> > > 
> > 
>
Mime
View raw message