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