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]
