You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Anirvan BASU <an...@inria.fr> on 2014/11/13 16:45:04 UTC

Please update BigDataClass.org source code on Github

Hello,

Has anyone used recently the source code on BigDataClass.org (using TF-IDF) ?
Specifically, with Flink 0.6 or 0.7 ?

We modified the programme source code in Java (also dependencies using the new pom.xml from quickstart, etc). 
with the domain name changes : eu.stratosphere --> org.apache.flink

Also,
some of the common functions have also changed locations (e.g.
eu.stratosphere.api.java.functions.FlatMapFunction --> org.apache.flink.api.java.common.functions.FlatMapFunction )

We tried to compile and none of the source code compiles correctly.

We received huge amount of errors :-((
Swimming in the dark - really helpless !

Could anyone please update the src and the pom.xml files on github to conform with flink 0.7 or even 0.6 ?

Below is the list of some of the errors.

Thanks in advance,
Anirvan

[QUOTE]

$ mvn clean package
[INFO] Scanning for projects...
[INFO]
[INFO] ------------------------------------------------------------------------
[INFO] Building Your Job's Name 0.1
[INFO] ------------------------------------------------------------------------
[INFO]
[INFO] --- maven-clean-plugin:2.5:clean (default-clean) @ quickstart ---
[INFO] Deleting /home/abasu/workspace/bigdataclass.org/exercise1/target
[INFO]
[INFO] --- maven-resources-plugin:2.6:resources (default-resources) @ quickstart ---
[INFO] Using 'UTF-8' encoding to copy filtered resources.
[INFO] skip non existing resourceDirectory /home/abasu/workspace/bigdataclass.org/exercise1/src/main/resources
[INFO]
[INFO] --- maven-compiler-plugin:3.1:compile (default-compile) @ quickstart ---
[INFO] Changes detected - recompiling the module!
[INFO] Compiling 12 source files to /home/abasu/workspace/bigdataclass.org/exercise1/target/classes
[INFO] -------------------------------------------------------------
[ERROR] COMPILATION ERROR :
[INFO] -------------------------------------------------------------
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task3/TfId.java:[37,8]
duplicate class: org.apache.flink.tutorial.task3.TfId
[ERROR]
/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task1/DocumentFrequency.java:[53,8]
duplicate class: org.apache.flink.tutorial.task1.DocumentFrequency
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task3/ReduceToVector.java:[17,8]
duplicate class: org.apache.flink.tutorial.task3.ReduceToVector
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task2/TermFrequency.java:[47,8]
duplicate class: org.apache.flink.tutorial.task2.TermFrequency
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/TfId.java:[20,43]
cannot find symbol
symbol: class JoinFunction
location: package org.apache.flink.api.java.functions
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task1/DocumentFrequency.java:[23,50]
package org.apache.flink.api.java.common.functions does not exist
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task1/DocumentFrequency.java:[24,50]
package org.apache.flink.api.java.common.functions does not exist
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task1/DocumentFrequency.java:[25,50]
package org.apache.flink.api.java.common.functions does not exist
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task2/TermFrequency.java:[22,46]
package org.apache.flink.java.common.functions does not exist
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/TfId.java:[104,26]
cannot find symbol
symbol: class JoinFunction
location: class org.apache.flink.tutorial.task3.TfId
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/ReduceToVector.java:[5,50]
package org.apache.flink.api.java.common.functions does not exist
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/ReduceToVector.java:[18,17]
cannot find symbol
symbol: class GroupReduceFunction
[ERROR]
/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task1/DocumentFrequency.java:[100,67]
cannot find symbol
symbol: class FlatMapFunction
location: class org.apache.flink.tutorial.task1.DocumentFrequency
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task1/DocumentFrequency.java:[120,68]
cannot find symbol
symbol: class GroupReduceFunction
location: class org.apache.flink.tutorial.task1.DocumentFrequency
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/util/Util.java:[28,30]
package com.google.common.base does not exist
[ERROR]
/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/util/Util.java:[29,30]
package com.google.common.base does not exist
[ERROR]
/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/util/Util.java:[30,28]
package com.google.common.io does not exist
[ERROR]
/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task2/TermFrequency.java:[93,58]
cannot find symbol
symbol: class FlatMapFunction
location: class org.apache.flink.tutorial.task2.TermFrequency
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task3/TfId.java:[20,43]
cannot find symbol
symbol: class JoinFunction
location: package org.apache.flink.api.java.functions
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task1/DocumentFrequency.java:[23,50]
package org.apache.flink.api.java.common.functions does not exist
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task1/DocumentFrequency.java:[24,50]
package org.apache.flink.api.java.common.functions does not exist
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task1/DocumentFrequency.java:[25,50]
package org.apache.flink.api.java.common.functions does not exist
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task3/ReduceToVector.java:[5,50]
package org.apache.flink.api.java.common.functions does not exist
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task2/TermFrequency.java:[22,46]
package org.apache.flink.java.common.functions does not exist
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task1/DocumentFrequency.java:[102,17]
method does not override or implement a method from a supertype
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task1/DocumentFrequency.java:[122,17]
method does not override or implement a method from a supertype
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task2/TermFrequency.java:[95,17]
method does not override or implement a method from a supertype
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/TfId.java:[58,33]
method flatMap in class org.apache.flink.api.java.DataSet<T>
cannot be applied to given types;
required: org.apache.flink.api.common.functions.FlatMapFunction<java.lang.String,R>
found: org.apache.flink.tutorial.task1.DocumentFrequency.DocumentFrequencyMapper

reason: no instance(s) of type variable(s) R exist so that argument
type
org.apache.flink.tutorial.task1.DocumentFrequency.DocumentFrequencyMapper
conforms to formal parameter type
org.apache.flink.api.common.functions.FlatMapFunction<java.lang.String,R>
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/TfId.java:[65,33]
method flatMap in class org.apache.flink.api.java.DataSet<T>
cannot be applied to given types;
required: org.apache.flink.api.common.functions.FlatMapFunction<java.lang.String,R>
found: org.apache.flink.tutorial.task2.TermFrequency.TermFreqMapper

reason: no instance(s) of type variable(s) R exist so that argument
type org.apache.flink.tutorial.task2.TermFrequency.TermFreqMapper
conforms to formal parameter type
org.apache.flink.api.common.functions.FlatMapFunction<java.lang.String,R>
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/TfId.java:[74,33]
no suitable method found for
with(org.apache.flink.tutorial.task3.TfId.TfIdCount)
method
org.apache.flink.api.java.operators.JoinOperator.DefaultJoin.<R>with(org.apache.flink.api.common.functions.JoinFunction<org.apache.flink.api.java.tuple.Tuple2<java.lang.String,java.lang.Integer>,org.apache.flink.api.java.tuple.Tuple3<java.lang.Integer,java.lang.String,java.lang.Integer>,R>)
is not applicable
(no instance(s) of type variable(s) R exist
so that argument type org.apache.flink.tutorial.task3.TfId.TfIdCount
conforms to formal parameter type
org.apache.flink.api.common.functions.JoinFunction<org.apache.flink.api.java.tuple.Tuple2<java.lang.String,java.lang.Integer>,org.apache.flink.api.java.tuple.Tuple3<java.lang.Integer,java.lang.String,java.lang.Integer>,R>)

method
org.apache.flink.api.java.operators.JoinOperator.DefaultJoin.<R>with(org.apache.flink.api.common.functions.FlatJoinFunction<org.apache.flink.api.java.tuple.Tuple2<java.lang.String,java.lang.Integer>,org.apache.flink.api.java.tuple.Tuple3<java.lang.Integer,java.lang.String,java.lang.Integer>,R>)
is not applicable
(no instance(s) of type variable(s) R exist
so that argument type org.apache.flink.tutorial.task3.TfId.TfIdCount
conforms to formal parameter type
org.apache.flink.api.common.functions.FlatJoinFunction<org.apache.flink.api.java.tuple.Tuple2<java.lang.String,java.lang.Integer>,org.apache.flink.api.java.tuple.Tuple3<java.lang.Integer,java.lang.String,java.lang.Integer>,R>)
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/TfId.java:[79,33]
method reduceGroup in class
org.apache.flink.api.java.operators.UnsortedGrouping<T> cannot be
applied to given types;
required:
org.apache.flink.api.common.functions.GroupReduceFunction<org.apache.flink.api.java.tuple.Tuple3<java.lang.Integer,java.lang.String,java.lang.Double>,R>
found: org.apache.flink.tutorial.task3.ReduceToVector

reason: no instance(s) of type variable(s) R exist so that argument
type org.apache.flink.tutorial.task3.ReduceToVector conforms to formal
parameter type
org.apache.flink.api.common.functions.GroupReduceFunction<org.apache.flink.api.java.tuple.Tuple3<java.lang.Integer,java.lang.String,java.lang.Double>,R>
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/TfId.java:[106,11]
method does not override or implement a method from a supertype
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/ReduceToVector.java:[26,23]
cannot find symbol
symbol: method setDocId(java.lang.Integer)
location: variable vector of type org.apache.flink.tutorial.task3.WeightVector
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/ReduceToVector.java:[27,23]
cannot find symbol
symbol: method add(java.lang.String,java.lang.Double)
location: variable vector of type org.apache.flink.tutorial.task3.WeightVector
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/ReduceToVector.java:[30,31]
cannot find symbol
symbol: method add(java.lang.String,java.lang.Double)
location: variable vector of type org.apache.flink.tutorial.task3.WeightVector
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/ReduceToVector.java:[20,9]
method does not override or implement a method from a supertype
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/util/Util.java:[181,42]
cannot find symbol
symbol: variable Charsets
location: class org.apache.flink.tutorial.util.Util
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/util/Util.java:[181,17]
cannot find symbol
symbol: variable Files
location: class org.apache.flink.tutorial.util.Util
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/util/Util.java:[198,31]
cannot find symbol
symbol: variable Throwables
location: class org.apache.flink.tutorial.util.Util
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/util/Util.java:[240,17]
cannot find symbol
symbol: variable Files
location: class org.apache.flink.tutorial.util.Util
[INFO] 40 errors
[INFO] -------------------------------------------------------------
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 2.271 s
[INFO] Finished at: 2014-11-13T16:33:08+01:00
[INFO] Final Memory: 19M/310M
[INFO] ------------------------------------------------------------------------
[ERROR]
Failed to execute goal
org.apache.maven.plugins:maven-compiler-plugin:3.1:compile
(default-compile) on project quickstart: Compilation failure:
Compilation failure:
[ERROR]
/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task3/TfId.java:[37,8]
duplicate class: org.apache.flink.tutorial.task3.TfId
[ERROR]
/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task1/DocumentFrequency.java:[53,8]
duplicate class: org.apache.flink.tutorial.task1.DocumentFrequency
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task3/ReduceToVector.java:[17,8]
duplicate class: org.apache.flink.tutorial.task3.ReduceToVector
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task2/TermFrequency.java:[47,8]
duplicate class: org.apache.flink.tutorial.task2.TermFrequency
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/TfId.java:[20,43]
cannot find symbol
[ERROR] symbol: class JoinFunction
[ERROR] location: package org.apache.flink.api.java.functions
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task1/DocumentFrequency.java:[23,50]
package org.apache.flink.api.java.common.functions does not exist
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task1/DocumentFrequency.java:[24,50]
package org.apache.flink.api.java.common.functions does not exist
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task1/DocumentFrequency.java:[25,50]
package org.apache.flink.api.java.common.functions does not exist
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task2/TermFrequency.java:[22,46]
package org.apache.flink.java.common.functions does not exist
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/TfId.java:[104,26]
cannot find symbol
[ERROR] symbol: class JoinFunction
[ERROR] location: class org.apache.flink.tutorial.task3.TfId
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/ReduceToVector.java:[5,50]
package org.apache.flink.api.java.common.functions does not exist
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/ReduceToVector.java:[18,17]
cannot find symbol
[ERROR] symbol: class GroupReduceFunction
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task1/DocumentFrequency.java:[100,67]
cannot find symbol
[ERROR] symbol: class FlatMapFunction
[ERROR] location: class org.apache.flink.tutorial.task1.DocumentFrequency
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task1/DocumentFrequency.java:[120,68]
cannot find symbol
[ERROR] symbol: class GroupReduceFunction
[ERROR] location: class org.apache.flink.tutorial.task1.DocumentFrequency
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/util/Util.java:[28,30]
package com.google.common.base does not exist
[ERROR]
/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/util/Util.java:[29,30]
package com.google.common.base does not exist
[ERROR]
/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/util/Util.java:[30,28]
package com.google.common.io does not exist
[ERROR]
/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task2/TermFrequency.java:[93,58]
cannot find symbol
[ERROR] symbol: class FlatMapFunction
[ERROR] location: class org.apache.flink.tutorial.task2.TermFrequency
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task3/TfId.java:[20,43]
cannot find symbol
[ERROR] symbol: class JoinFunction
[ERROR] location: package org.apache.flink.api.java.functions
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task1/DocumentFrequency.java:[23,50]
package org.apache.flink.api.java.common.functions does not exist
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task1/DocumentFrequency.java:[24,50]
package org.apache.flink.api.java.common.functions does not exist
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task1/DocumentFrequency.java:[25,50]
package org.apache.flink.api.java.common.functions does not exist
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task3/ReduceToVector.java:[5,50]
package org.apache.flink.api.java.common.functions does not exist
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task2/TermFrequency.java:[22,46]
package org.apache.flink.java.common.functions does not exist
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task1/DocumentFrequency.java:[102,17]
method does not override or implement a method from a supertype
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task1/DocumentFrequency.java:[122,17]
method does not override or implement a method from a supertype
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task2/TermFrequency.java:[95,17]
method does not override or implement a method from a supertype
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/TfId.java:[58,33]
method flatMap in class org.apache.flink.api.java.DataSet<T>
cannot be applied to given types;
[ERROR] required: org.apache.flink.api.common.functions.FlatMapFunction<java.lang.String,R>
[ERROR] found: org.apache.flink.tutorial.task1.DocumentFrequency.DocumentFrequencyMapper
[ERROR]
reason: no instance(s) of type variable(s) R exist so that argument
type
org.apache.flink.tutorial.task1.DocumentFrequency.DocumentFrequencyMapper
conforms to formal parameter type
org.apache.flink.api.common.functions.FlatMapFunction<java.lang.String,R>
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/TfId.java:[65,33]
method flatMap in class org.apache.flink.api.java.DataSet<T>
cannot be applied to given types;
[ERROR] required: org.apache.flink.api.common.functions.FlatMapFunction<java.lang.String,R>
[ERROR] found: org.apache.flink.tutorial.task2.TermFrequency.TermFreqMapper
[ERROR]
reason: no instance(s) of type variable(s) R exist so that argument
type org.apache.flink.tutorial.task2.TermFrequency.TermFreqMapper
conforms to formal parameter type
org.apache.flink.api.common.functions.FlatMapFunction<java.lang.String,R>
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/TfId.java:[74,33]
no suitable method found for
with(org.apache.flink.tutorial.task3.TfId.TfIdCount)
[ERROR] method
org.apache.flink.api.java.operators.JoinOperator.DefaultJoin.<R>with(org.apache.flink.api.common.functions.JoinFunction<org.apache.flink.api.java.tuple.Tuple2<java.lang.String,java.lang.Integer>,org.apache.flink.api.java.tuple.Tuple3<java.lang.Integer,java.lang.String,java.lang.Integer>,R>)
is not applicable
[ERROR] (no instance(s) of type variable(s) R
exist so that argument type
org.apache.flink.tutorial.task3.TfId.TfIdCount conforms to formal
parameter type
org.apache.flink.api.common.functions.JoinFunction<org.apache.flink.api.java.tuple.Tuple2<java.lang.String,java.lang.Integer>,org.apache.flink.api.java.tuple.Tuple3<java.lang.Integer,java.lang.String,java.lang.Integer>,R>)
[ERROR]
method
org.apache.flink.api.java.operators.JoinOperator.DefaultJoin.<R>with(org.apache.flink.api.common.functions.FlatJoinFunction<org.apache.flink.api.java.tuple.Tuple2<java.lang.String,java.lang.Integer>,org.apache.flink.api.java.tuple.Tuple3<java.lang.Integer,java.lang.String,java.lang.Integer>,R>)
is not applicable
[ERROR] (no instance(s) of type variable(s) R
exist so that argument type
org.apache.flink.tutorial.task3.TfId.TfIdCount conforms to formal
parameter type
org.apache.flink.api.common.functions.FlatJoinFunction<org.apache.flink.api.java.tuple.Tuple2<java.lang.String,java.lang.Integer>,org.apache.flink.api.java.tuple.Tuple3<java.lang.Integer,java.lang.String,java.lang.Integer>,R>)
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/TfId.java:[79,33]
method reduceGroup in class
org.apache.flink.api.java.operators.UnsortedGrouping<T> cannot be
applied to given types;
[ERROR] required:
org.apache.flink.api.common.functions.GroupReduceFunction<org.apache.flink.api.java.tuple.Tuple3<java.lang.Integer,java.lang.String,java.lang.Double>,R>
[ERROR] found: org.apache.flink.tutorial.task3.ReduceToVector
[ERROR]
reason: no instance(s) of type variable(s) R exist so that argument
type org.apache.flink.tutorial.task3.ReduceToVector conforms to formal
parameter type
org.apache.flink.api.common.functions.GroupReduceFunction<org.apache.flink.api.java.tuple.Tuple3<java.lang.Integer,java.lang.String,java.lang.Double>,R>
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/TfId.java:[106,11]
method does not override or implement a method from a supertype
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/ReduceToVector.java:[26,23]
cannot find symbol
[ERROR] symbol: method setDocId(java.lang.Integer)
[ERROR] location: variable vector of type org.apache.flink.tutorial.task3.WeightVector
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/ReduceToVector.java:[27,23]
cannot find symbol
[ERROR] symbol: method add(java.lang.String,java.lang.Double)
[ERROR] location: variable vector of type org.apache.flink.tutorial.task3.WeightVector
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/ReduceToVector.java:[30,31]
cannot find symbol
[ERROR] symbol: method add(java.lang.String,java.lang.Double)
[ERROR] location: variable vector of type org.apache.flink.tutorial.task3.WeightVector
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/ReduceToVector.java:[20,9]
method does not override or implement a method from a supertype
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/util/Util.java:[181,42]
cannot find symbol
[ERROR] symbol: variable Charsets
[ERROR] location: class org.apache.flink.tutorial.util.Util
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/util/Util.java:[181,17]
cannot find symbol
[ERROR] symbol: variable Files
[ERROR] location: class org.apache.flink.tutorial.util.Util
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/util/Util.java:[198,31]
cannot find symbol
[ERROR] symbol: variable Throwables
[ERROR] location: class org.apache.flink.tutorial.util.Util
[ERROR]

/home/abasu/workspace/bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/util/Util.java:[240,17]
cannot find symbol
[ERROR] symbol: variable Files
[ERROR] location: class org.apache.flink.tutorial.util.Util
[ERROR] -> [Help 1]
[ERROR]
[ERROR] To see the full stack trace of the errors, re-run Maven with the -e switch.
[ERROR] Re-run Maven using the -X switch to enable full debug logging.
[ERROR]
[ERROR] For more information about the errors and possible solutions, please read the following articles:
[ERROR] [Help 1] http://cwiki.apache.org/confluence/display/MAVEN/MojoFailureException
[/QUOTE]

Re: Please update BigDataClass.org source code on Github

Posted by Kostas Tzoumas <kt...@apache.org>.

That's true, that website has not been maintained for a while. That website
is not part of Apache Flink, so this mailing list might not be the best
place to ask for help. Perhaps someone that is reading this will pick it up
though.

It looks like you need to forward-port the job to the current Java API
(among a few other Java errors). There have been more changes to the API
between 0.5 and 0.7 than simple renaming of the packages.



On Thu, Nov 13, 2014 at 4:45 PM, Anirvan BASU <an...@inria.fr> wrote:

> Hello,
>
> Has anyone used recently the source code on BigDataClass.org (using
> TF-IDF) ?
> Specifically, with Flink 0.6 or 0.7 ?
>
> We modified the programme source code in Java (also dependencies using the
> new pom.xml from quickstart, etc).
> with the domain name changes : eu.stratosphere --> org.apache.flink
>
> Also,
> some of the common functions have also changed locations (e.g.
> eu.stratosphere.api.java.functions.FlatMapFunction -->
> org.apache.flink.api.java.common.functions.FlatMapFunction )
>
> We tried to compile and none of the source code compiles correctly.
>
> We received huge amount of errors :-((
> Swimming in the dark - really helpless !
>
> Could anyone please update the src and the pom.xml files on github to
> conform with flink 0.7 or even 0.6 ?
>
> Below is the list of some of the errors.
>
> Thanks in advance,
> Anirvan
>
> [QUOTE]
>
> $ mvn clean package
> [INFO] Scanning for projects...
> [INFO]
> [INFO]
> ------------------------------------------------------------------------
> [INFO] Building Your Job's Name 0.1
> [INFO]
> ------------------------------------------------------------------------
> [INFO]
> [INFO] --- maven-clean-plugin:2.5:clean (default-clean) @ quickstart ---
> [INFO] Deleting /home/abasu/workspace/bigdataclass.org/exercise1/target
> [INFO]
> [INFO] --- maven-resources-plugin:2.6:resources (default-resources) @
> quickstart ---
> [INFO] Using 'UTF-8' encoding to copy filtered resources.
> [INFO] skip non existing resourceDirectory /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/resources
> [INFO]
> [INFO] --- maven-compiler-plugin:3.1:compile (default-compile) @
> quickstart ---
> [INFO] Changes detected - recompiling the module!
> [INFO] Compiling 12 source files to /home/abasu/workspace/
> bigdataclass.org/exercise1/target/classes
> [INFO] -------------------------------------------------------------
> [ERROR] COMPILATION ERROR :
> [INFO] -------------------------------------------------------------
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task3/TfId.java:[37,8]
> duplicate class: org.apache.flink.tutorial.task3.TfId
> [ERROR]
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task1/DocumentFrequency.java:[53,8]
> duplicate class: org.apache.flink.tutorial.task1.DocumentFrequency
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task3/ReduceToVector.java:[17,8]
> duplicate class: org.apache.flink.tutorial.task3.ReduceToVector
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task2/TermFrequency.java:[47,8]
> duplicate class: org.apache.flink.tutorial.task2.TermFrequency
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/TfId.java:[20,43]
> cannot find symbol
> symbol: class JoinFunction
> location: package org.apache.flink.api.java.functions
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task1/DocumentFrequency.java:[23,50]
> package org.apache.flink.api.java.common.functions does not exist
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task1/DocumentFrequency.java:[24,50]
> package org.apache.flink.api.java.common.functions does not exist
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task1/DocumentFrequency.java:[25,50]
> package org.apache.flink.api.java.common.functions does not exist
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task2/TermFrequency.java:[22,46]
> package org.apache.flink.java.common.functions does not exist
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/TfId.java:[104,26]
> cannot find symbol
> symbol: class JoinFunction
> location: class org.apache.flink.tutorial.task3.TfId
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/ReduceToVector.java:[5,50]
> package org.apache.flink.api.java.common.functions does not exist
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/ReduceToVector.java:[18,17]
> cannot find symbol
> symbol: class GroupReduceFunction
> [ERROR]
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task1/DocumentFrequency.java:[100,67]
> cannot find symbol
> symbol: class FlatMapFunction
> location: class org.apache.flink.tutorial.task1.DocumentFrequency
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task1/DocumentFrequency.java:[120,68]
> cannot find symbol
> symbol: class GroupReduceFunction
> location: class org.apache.flink.tutorial.task1.DocumentFrequency
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/util/Util.java:[28,30]
> package com.google.common.base does not exist
> [ERROR]
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/util/Util.java:[29,30]
> package com.google.common.base does not exist
> [ERROR]
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/util/Util.java:[30,28]
> package com.google.common.io does not exist
> [ERROR]
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task2/TermFrequency.java:[93,58]
> cannot find symbol
> symbol: class FlatMapFunction
> location: class org.apache.flink.tutorial.task2.TermFrequency
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task3/TfId.java:[20,43]
> cannot find symbol
> symbol: class JoinFunction
> location: package org.apache.flink.api.java.functions
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task1/DocumentFrequency.java:[23,50]
> package org.apache.flink.api.java.common.functions does not exist
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task1/DocumentFrequency.java:[24,50]
> package org.apache.flink.api.java.common.functions does not exist
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task1/DocumentFrequency.java:[25,50]
> package org.apache.flink.api.java.common.functions does not exist
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task3/ReduceToVector.java:[5,50]
> package org.apache.flink.api.java.common.functions does not exist
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task2/TermFrequency.java:[22,46]
> package org.apache.flink.java.common.functions does not exist
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task1/DocumentFrequency.java:[102,17]
> method does not override or implement a method from a supertype
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task1/DocumentFrequency.java:[122,17]
> method does not override or implement a method from a supertype
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task2/TermFrequency.java:[95,17]
> method does not override or implement a method from a supertype
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/TfId.java:[58,33]
> method flatMap in class org.apache.flink.api.java.DataSet<T>
> cannot be applied to given types;
> required:
> org.apache.flink.api.common.functions.FlatMapFunction<java.lang.String,R>
> found:
> org.apache.flink.tutorial.task1.DocumentFrequency.DocumentFrequencyMapper
>
> reason: no instance(s) of type variable(s) R exist so that argument
> type
> org.apache.flink.tutorial.task1.DocumentFrequency.DocumentFrequencyMapper
> conforms to formal parameter type
> org.apache.flink.api.common.functions.FlatMapFunction<java.lang.String,R>
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/TfId.java:[65,33]
> method flatMap in class org.apache.flink.api.java.DataSet<T>
> cannot be applied to given types;
> required:
> org.apache.flink.api.common.functions.FlatMapFunction<java.lang.String,R>
> found: org.apache.flink.tutorial.task2.TermFrequency.TermFreqMapper
>
> reason: no instance(s) of type variable(s) R exist so that argument
> type org.apache.flink.tutorial.task2.TermFrequency.TermFreqMapper
> conforms to formal parameter type
> org.apache.flink.api.common.functions.FlatMapFunction<java.lang.String,R>
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/TfId.java:[74,33]
> no suitable method found for
> with(org.apache.flink.tutorial.task3.TfId.TfIdCount)
> method
>
> org.apache.flink.api.java.operators.JoinOperator.DefaultJoin.<R>with(org.apache.flink.api.common.functions.JoinFunction<org.apache.flink.api.java.tuple.Tuple2<java.lang.String,java.lang.Integer>,org.apache.flink.api.java.tuple.Tuple3<java.lang.Integer,java.lang.String,java.lang.Integer>,R>)
> is not applicable
> (no instance(s) of type variable(s) R exist
> so that argument type org.apache.flink.tutorial.task3.TfId.TfIdCount
> conforms to formal parameter type
>
> org.apache.flink.api.common.functions.JoinFunction<org.apache.flink.api.java.tuple.Tuple2<java.lang.String,java.lang.Integer>,org.apache.flink.api.java.tuple.Tuple3<java.lang.Integer,java.lang.String,java.lang.Integer>,R>)
>
> method
>
> org.apache.flink.api.java.operators.JoinOperator.DefaultJoin.<R>with(org.apache.flink.api.common.functions.FlatJoinFunction<org.apache.flink.api.java.tuple.Tuple2<java.lang.String,java.lang.Integer>,org.apache.flink.api.java.tuple.Tuple3<java.lang.Integer,java.lang.String,java.lang.Integer>,R>)
> is not applicable
> (no instance(s) of type variable(s) R exist
> so that argument type org.apache.flink.tutorial.task3.TfId.TfIdCount
> conforms to formal parameter type
>
> org.apache.flink.api.common.functions.FlatJoinFunction<org.apache.flink.api.java.tuple.Tuple2<java.lang.String,java.lang.Integer>,org.apache.flink.api.java.tuple.Tuple3<java.lang.Integer,java.lang.String,java.lang.Integer>,R>)
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/TfId.java:[79,33]
> method reduceGroup in class
> org.apache.flink.api.java.operators.UnsortedGrouping<T> cannot be
> applied to given types;
> required:
>
> org.apache.flink.api.common.functions.GroupReduceFunction<org.apache.flink.api.java.tuple.Tuple3<java.lang.Integer,java.lang.String,java.lang.Double>,R>
> found: org.apache.flink.tutorial.task3.ReduceToVector
>
> reason: no instance(s) of type variable(s) R exist so that argument
> type org.apache.flink.tutorial.task3.ReduceToVector conforms to formal
> parameter type
>
> org.apache.flink.api.common.functions.GroupReduceFunction<org.apache.flink.api.java.tuple.Tuple3<java.lang.Integer,java.lang.String,java.lang.Double>,R>
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/TfId.java:[106,11]
> method does not override or implement a method from a supertype
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/ReduceToVector.java:[26,23]
> cannot find symbol
> symbol: method setDocId(java.lang.Integer)
> location: variable vector of type
> org.apache.flink.tutorial.task3.WeightVector
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/ReduceToVector.java:[27,23]
> cannot find symbol
> symbol: method add(java.lang.String,java.lang.Double)
> location: variable vector of type
> org.apache.flink.tutorial.task3.WeightVector
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/ReduceToVector.java:[30,31]
> cannot find symbol
> symbol: method add(java.lang.String,java.lang.Double)
> location: variable vector of type
> org.apache.flink.tutorial.task3.WeightVector
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/ReduceToVector.java:[20,9]
> method does not override or implement a method from a supertype
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/util/Util.java:[181,42]
> cannot find symbol
> symbol: variable Charsets
> location: class org.apache.flink.tutorial.util.Util
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/util/Util.java:[181,17]
> cannot find symbol
> symbol: variable Files
> location: class org.apache.flink.tutorial.util.Util
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/util/Util.java:[198,31]
> cannot find symbol
> symbol: variable Throwables
> location: class org.apache.flink.tutorial.util.Util
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/util/Util.java:[240,17]
> cannot find symbol
> symbol: variable Files
> location: class org.apache.flink.tutorial.util.Util
> [INFO] 40 errors
> [INFO] -------------------------------------------------------------
> [INFO]
> ------------------------------------------------------------------------
> [INFO] BUILD FAILURE
> [INFO]
> ------------------------------------------------------------------------
> [INFO] Total time: 2.271 s
> [INFO] Finished at: 2014-11-13T16:33:08+01:00
> [INFO] Final Memory: 19M/310M
> [INFO]
> ------------------------------------------------------------------------
> [ERROR]
> Failed to execute goal
> org.apache.maven.plugins:maven-compiler-plugin:3.1:compile
> (default-compile) on project quickstart: Compilation failure:
> Compilation failure:
> [ERROR]
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task3/TfId.java:[37,8]
> duplicate class: org.apache.flink.tutorial.task3.TfId
> [ERROR]
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task1/DocumentFrequency.java:[53,8]
> duplicate class: org.apache.flink.tutorial.task1.DocumentFrequency
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task3/ReduceToVector.java:[17,8]
> duplicate class: org.apache.flink.tutorial.task3.ReduceToVector
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task2/TermFrequency.java:[47,8]
> duplicate class: org.apache.flink.tutorial.task2.TermFrequency
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/TfId.java:[20,43]
> cannot find symbol
> [ERROR] symbol: class JoinFunction
> [ERROR] location: package org.apache.flink.api.java.functions
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task1/DocumentFrequency.java:[23,50]
> package org.apache.flink.api.java.common.functions does not exist
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task1/DocumentFrequency.java:[24,50]
> package org.apache.flink.api.java.common.functions does not exist
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task1/DocumentFrequency.java:[25,50]
> package org.apache.flink.api.java.common.functions does not exist
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task2/TermFrequency.java:[22,46]
> package org.apache.flink.java.common.functions does not exist
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/TfId.java:[104,26]
> cannot find symbol
> [ERROR] symbol: class JoinFunction
> [ERROR] location: class org.apache.flink.tutorial.task3.TfId
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/ReduceToVector.java:[5,50]
> package org.apache.flink.api.java.common.functions does not exist
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/ReduceToVector.java:[18,17]
> cannot find symbol
> [ERROR] symbol: class GroupReduceFunction
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task1/DocumentFrequency.java:[100,67]
> cannot find symbol
> [ERROR] symbol: class FlatMapFunction
> [ERROR] location: class org.apache.flink.tutorial.task1.DocumentFrequency
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task1/DocumentFrequency.java:[120,68]
> cannot find symbol
> [ERROR] symbol: class GroupReduceFunction
> [ERROR] location: class org.apache.flink.tutorial.task1.DocumentFrequency
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/util/Util.java:[28,30]
> package com.google.common.base does not exist
> [ERROR]
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/util/Util.java:[29,30]
> package com.google.common.base does not exist
> [ERROR]
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/util/Util.java:[30,28]
> package com.google.common.io does not exist
> [ERROR]
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task2/TermFrequency.java:[93,58]
> cannot find symbol
> [ERROR] symbol: class FlatMapFunction
> [ERROR] location: class org.apache.flink.tutorial.task2.TermFrequency
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task3/TfId.java:[20,43]
> cannot find symbol
> [ERROR] symbol: class JoinFunction
> [ERROR] location: package org.apache.flink.api.java.functions
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task1/DocumentFrequency.java:[23,50]
> package org.apache.flink.api.java.common.functions does not exist
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task1/DocumentFrequency.java:[24,50]
> package org.apache.flink.api.java.common.functions does not exist
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task1/DocumentFrequency.java:[25,50]
> package org.apache.flink.api.java.common.functions does not exist
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task3/ReduceToVector.java:[5,50]
> package org.apache.flink.api.java.common.functions does not exist
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task2/TermFrequency.java:[22,46]
> package org.apache.flink.java.common.functions does not exist
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task1/DocumentFrequency.java:[102,17]
> method does not override or implement a method from a supertype
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task1/DocumentFrequency.java:[122,17]
> method does not override or implement a method from a supertype
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/task2/TermFrequency.java:[95,17]
> method does not override or implement a method from a supertype
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/TfId.java:[58,33]
> method flatMap in class org.apache.flink.api.java.DataSet<T>
> cannot be applied to given types;
> [ERROR] required:
> org.apache.flink.api.common.functions.FlatMapFunction<java.lang.String,R>
> [ERROR] found:
> org.apache.flink.tutorial.task1.DocumentFrequency.DocumentFrequencyMapper
> [ERROR]
> reason: no instance(s) of type variable(s) R exist so that argument
> type
> org.apache.flink.tutorial.task1.DocumentFrequency.DocumentFrequencyMapper
> conforms to formal parameter type
> org.apache.flink.api.common.functions.FlatMapFunction<java.lang.String,R>
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/TfId.java:[65,33]
> method flatMap in class org.apache.flink.api.java.DataSet<T>
> cannot be applied to given types;
> [ERROR] required:
> org.apache.flink.api.common.functions.FlatMapFunction<java.lang.String,R>
> [ERROR] found: org.apache.flink.tutorial.task2.TermFrequency.TermFreqMapper
> [ERROR]
> reason: no instance(s) of type variable(s) R exist so that argument
> type org.apache.flink.tutorial.task2.TermFrequency.TermFreqMapper
> conforms to formal parameter type
> org.apache.flink.api.common.functions.FlatMapFunction<java.lang.String,R>
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/TfId.java:[74,33]
> no suitable method found for
> with(org.apache.flink.tutorial.task3.TfId.TfIdCount)
> [ERROR] method
>
> org.apache.flink.api.java.operators.JoinOperator.DefaultJoin.<R>with(org.apache.flink.api.common.functions.JoinFunction<org.apache.flink.api.java.tuple.Tuple2<java.lang.String,java.lang.Integer>,org.apache.flink.api.java.tuple.Tuple3<java.lang.Integer,java.lang.String,java.lang.Integer>,R>)
> is not applicable
> [ERROR] (no instance(s) of type variable(s) R
> exist so that argument type
> org.apache.flink.tutorial.task3.TfId.TfIdCount conforms to formal
> parameter type
>
> org.apache.flink.api.common.functions.JoinFunction<org.apache.flink.api.java.tuple.Tuple2<java.lang.String,java.lang.Integer>,org.apache.flink.api.java.tuple.Tuple3<java.lang.Integer,java.lang.String,java.lang.Integer>,R>)
> [ERROR]
> method
>
> org.apache.flink.api.java.operators.JoinOperator.DefaultJoin.<R>with(org.apache.flink.api.common.functions.FlatJoinFunction<org.apache.flink.api.java.tuple.Tuple2<java.lang.String,java.lang.Integer>,org.apache.flink.api.java.tuple.Tuple3<java.lang.Integer,java.lang.String,java.lang.Integer>,R>)
> is not applicable
> [ERROR] (no instance(s) of type variable(s) R
> exist so that argument type
> org.apache.flink.tutorial.task3.TfId.TfIdCount conforms to formal
> parameter type
>
> org.apache.flink.api.common.functions.FlatJoinFunction<org.apache.flink.api.java.tuple.Tuple2<java.lang.String,java.lang.Integer>,org.apache.flink.api.java.tuple.Tuple3<java.lang.Integer,java.lang.String,java.lang.Integer>,R>)
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/TfId.java:[79,33]
> method reduceGroup in class
> org.apache.flink.api.java.operators.UnsortedGrouping<T> cannot be
> applied to given types;
> [ERROR] required:
>
> org.apache.flink.api.common.functions.GroupReduceFunction<org.apache.flink.api.java.tuple.Tuple3<java.lang.Integer,java.lang.String,java.lang.Double>,R>
> [ERROR] found: org.apache.flink.tutorial.task3.ReduceToVector
> [ERROR]
> reason: no instance(s) of type variable(s) R exist so that argument
> type org.apache.flink.tutorial.task3.ReduceToVector conforms to formal
> parameter type
>
> org.apache.flink.api.common.functions.GroupReduceFunction<org.apache.flink.api.java.tuple.Tuple3<java.lang.Integer,java.lang.String,java.lang.Double>,R>
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/TfId.java:[106,11]
> method does not override or implement a method from a supertype
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/ReduceToVector.java:[26,23]
> cannot find symbol
> [ERROR] symbol: method setDocId(java.lang.Integer)
> [ERROR] location: variable vector of type
> org.apache.flink.tutorial.task3.WeightVector
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/ReduceToVector.java:[27,23]
> cannot find symbol
> [ERROR] symbol: method add(java.lang.String,java.lang.Double)
> [ERROR] location: variable vector of type
> org.apache.flink.tutorial.task3.WeightVector
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/ReduceToVector.java:[30,31]
> cannot find symbol
> [ERROR] symbol: method add(java.lang.String,java.lang.Double)
> [ERROR] location: variable vector of type
> org.apache.flink.tutorial.task3.WeightVector
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/answerKey/task3/ReduceToVector.java:[20,9]
> method does not override or implement a method from a supertype
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/util/Util.java:[181,42]
> cannot find symbol
> [ERROR] symbol: variable Charsets
> [ERROR] location: class org.apache.flink.tutorial.util.Util
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/util/Util.java:[181,17]
> cannot find symbol
> [ERROR] symbol: variable Files
> [ERROR] location: class org.apache.flink.tutorial.util.Util
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/util/Util.java:[198,31]
> cannot find symbol
> [ERROR] symbol: variable Throwables
> [ERROR] location: class org.apache.flink.tutorial.util.Util
> [ERROR]
>
> /home/abasu/workspace/
> bigdataclass.org/exercise1/src/main/java/org/apache/flink/tutorial/util/Util.java:[240,17]
> cannot find symbol
> [ERROR] symbol: variable Files
> [ERROR] location: class org.apache.flink.tutorial.util.Util
> [ERROR] -> [Help 1]
> [ERROR]
> [ERROR] To see the full stack trace of the errors, re-run Maven with the
> -e switch.
> [ERROR] Re-run Maven using the -X switch to enable full debug logging.
> [ERROR]
> [ERROR] For more information about the errors and possible solutions,
> please read the following articles:
> [ERROR] [Help 1]
> http://cwiki.apache.org/confluence/display/MAVEN/MojoFailureException
> [/QUOTE]
>