flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Anirvan BASU <anirvan.b...@inria.fr>
Subject Please update BigDataClass.org source code on Github
Date Thu, 13 Nov 2014 15:45:04 GMT
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]

Mime
View raw message