Please update BigDataClass.org source code on Github
Locked
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
|
|
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 <[hidden email]> wrote: Hello, |
«
Return to (DEPRECATED) Apache Flink User Mailing List archive.
|
1 view|%1 views
| Free forum by Nabble | Edit this page |