Compiling Flink on macOS.
Locked
 
|
Hi all,
My name is Lior and I an new to this community. I am working on enhancing the python API of Flink (batch). I am having some issues compiling Flink on macOS with the latest master, it seems that flink-storm-examples module is failing. A quick question, how can I skip this module when I am compiling on Mac? (it fine on our Linux cluster). Regards --lior |
|
|
Can you show the error(s) you got ? What is the Java version you're using ? Thanks On Wed, Feb 22, 2017 at 10:24 AM, Lior Amar <[hidden email]> wrote:
|
|
|
lior@MacBook-Pro-2 ~/src/flink/flink/flink-contrib/flink-storm-examples (pm/lior/py_tests) $ mvn install [INFO] Scanning for projects... [INFO] [INFO] ------------------------------------------------------------------------ [INFO] Building flink-storm-examples 1.3-SNAPSHOT [INFO] ------------------------------------------------------------------------ [INFO] [INFO] --- maven-checkstyle-plugin:2.17:check (validate) @ flink-storm-examples_2.10 --- [INFO] [INFO] --- maven-enforcer-plugin:1.4.1:enforce (enforce-maven) @ flink-storm-examples_2.10 --- [INFO] [INFO] --- maven-remote-resources-plugin:1.5:process (process-resource-bundles) @ flink-storm-examples_2.10 --- [INFO] [INFO] --- maven-resources-plugin:2.7:resources (default-resources) @ flink-storm-examples_2.10 --- [INFO] Using 'UTF-8' encoding to copy filtered resources. [INFO] skip non existing resourceDirectory /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/resources [INFO] Copying 3 resources [INFO] [INFO] --- maven-compiler-plugin:3.1:compile (default-compile) @ flink-storm-examples_2.10 --- [INFO] Changes detected - recompiling the module! [INFO] Compiling 38 source files to /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/target/classes [INFO] ------------------------------------------------------------- [WARNING] COMPILATION WARNING : [INFO] ------------------------------------------------------------- [WARNING] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/wordcount/WordCountRemoteByClient.java:[72,32] NIMBUS_HOST in org.apache.storm.Config has been deprecated [WARNING] Some messages have been simplified; recompile with -Xdiags:verbose to get full output [INFO] 2 warnings [INFO] ------------------------------------------------------------- [INFO] ------------------------------------------------------------- [ERROR] COMPILATION ERROR : [INFO] ------------------------------------------------------------- [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/util/FiniteInMemorySpout.java:[25,8] cannot access backtype.storm.topology.IRichSpout class file for backtype.storm.topology.IRichSpout not found [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/exclamation/ExclamationWithBolt.java:[73,49] cannot access backtype.storm.topology.IRichBolt class file for backtype.storm.topology.IRichBolt not found [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/join/SingleJoinExample.java:[47,88] incompatible types: org.apache.storm.testing.FeederSpout cannot be converted to backtype.storm.topology.IRichSpout [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/join/SingleJoinExample.java:[48,86] incompatible types: org.apache.storm.testing.FeederSpout cannot be converted to backtype.storm.topology.IRichSpout [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/join/SingleJoinExample.java:[50,44] incompatible types: org.apache.flink.storm.util.NullTerminatingSpout cannot be converted to org.apache.storm.topology.IRichSpout [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/join/SingleJoinExample.java:[51,41] incompatible types: org.apache.flink.storm.util.NullTerminatingSpout cannot be converted to org.apache.storm.topology.IRichSpout [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/join/SingleJoinExample.java:[84,75] cannot access backtype.storm.topology.TopologyBuilder class file for backtype.storm.topology.TopologyBuilder not found [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/util/FiniteInMemorySpout.java:[32,9] method does not override or implement a method from a supertype [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/wordcount/WordCountTopology.java:[73,76] incompatible types: org.apache.flink.storm.wordcount.operators.WordCountFileSpout cannot be converted to backtype.storm.topology.IRichSpout [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/exclamation/ExclamationLocal.java:[68,87] incompatible types: org.apache.storm.topology.TopologyBuilder cannot be converted to backtype.storm.topology.TopologyBuilder [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/print/PrintSampleStream.java:[63,84] incompatible types: org.apache.storm.topology.TopologyBuilder cannot be converted to backtype.storm.topology.TopologyBuilder [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/wordcount/WordCountLocalByName.java:[67,87] incompatible types: org.apache.storm.topology.TopologyBuilder cannot be converted to backtype.storm.topology.TopologyBuilder [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/wordcount/BoltTokenizerWordCountPojo.java:[73,100] incompatible types: org.apache.flink.storm.wordcount.operators.BoltTokenizerByName cannot be converted to backtype.storm.topology.IRichBolt [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/wordcount/WordCountRemoteBySubmitter.java:[75,94] incompatible types: org.apache.storm.topology.TopologyBuilder cannot be converted to backtype.storm.topology.TopologyBuilder [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/wordcount/WordCountRemoteByClient.java:[77,102] incompatible types: org.apache.storm.topology.TopologyBuilder cannot be converted to backtype.storm.topology.TopologyBuilder [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/wordcount/BoltTokenizerWordCountWithNames.java:[76,49] no suitable constructor found for BoltWrapper(org.apache.flink.storm.wordcount.operators.BoltTokenizerByName,org.apache.storm.tuple.Fields) constructor org.apache.flink.storm.wrappers.BoltWrapper.BoltWrapper(backtype.storm.topology.IRichBolt,backtype.storm.tuple.Fields) is not applicable (argument mismatch; org.apache.flink.storm.wordcount.operators.BoltTokenizerByName cannot be converted to backtype.storm.topology.IRichBolt) constructor org.apache.flink.storm.wrappers.BoltWrapper.BoltWrapper(backtype.storm.topology.IRichBolt,java.lang.String[]) is not applicable (argument mismatch; org.apache.flink.storm.wordcount.operators.BoltTokenizerByName cannot be converted to backtype.storm.topology.IRichBolt) constructor org.apache.flink.storm.wrappers.BoltWrapper.BoltWrapper(backtype.storm.topology.IRichBolt,java.util.Collection<java.lang.String>) is not applicable (argument mismatch; org.apache.flink.storm.wordcount.operators.BoltTokenizerByName cannot be converted to backtype.storm.topology.IRichBolt) [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/exclamation/ExclamationWithSpout.java:[134,41] no suitable constructor found for SpoutWrapper(org.apache.flink.storm.util.FiniteFileSpout,java.lang.String[]) constructor org.apache.flink.storm.wrappers.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpout,java.lang.Integer) is not applicable (argument mismatch; org.apache.flink.storm.util.FiniteFileSpout cannot be converted to backtype.storm.topology.IRichSpout) constructor org.apache.flink.storm.wrappers.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpout,java.lang.String[]) is not applicable (argument mismatch; org.apache.flink.storm.util.FiniteFileSpout cannot be converted to backtype.storm.topology.IRichSpout) constructor org.apache.flink.storm.wrappers.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpout,java.util.Collection<java.lang.String>) is not applicable (argument mismatch; org.apache.flink.storm.util.FiniteFileSpout cannot be converted to backtype.storm.topology.IRichSpout) [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/exclamation/ExclamationWithSpout.java:[140,33] no suitable constructor found for SpoutWrapper(org.apache.flink.storm.util.FiniteInMemorySpout,java.lang.String[]) constructor org.apache.flink.storm.wrappers.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpout,java.lang.Integer) is not applicable (argument mismatch; org.apache.flink.storm.util.FiniteInMemorySpout cannot be converted to backtype.storm.topology.IRichSpout) constructor org.apache.flink.storm.wrappers.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpout,java.lang.String[]) is not applicable (argument mismatch; org.apache.flink.storm.util.FiniteInMemorySpout cannot be converted to backtype.storm.topology.IRichSpout) constructor org.apache.flink.storm.wrappers.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpout,java.util.Collection<java.lang.String>) is not applicable (argument mismatch; org.apache.flink.storm.util.FiniteInMemorySpout cannot be converted to backtype.storm.topology.IRichSpout) [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/wordcount/BoltTokenizerWordCount.java:[66,98] incompatible types: org.apache.flink.storm.wordcount.operators.BoltTokenizer cannot be converted to backtype.storm.topology.IRichBolt [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/split/SpoutSplitExample.java:[62,33] no suitable constructor found for SpoutWrapper(org.apache.flink.storm.split.operators.RandomSpout,java.lang.String[],int) constructor org.apache.flink.storm.wrappers.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpout,java.lang.String[],java.lang.Integer) is not applicable (argument mismatch; org.apache.flink.storm.split.operators.RandomSpout cannot be converted to backtype.storm.topology.IRichSpout) constructor org.apache.flink.storm.wrappers.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpout,java.util.Collection<java.lang.String>,java.lang.Integer) is not applicable (argument mismatch; org.apache.flink.storm.split.operators.RandomSpout cannot be converted to backtype.storm.topology.IRichSpout) [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/split/SpoutSplitExample.java:[76,99] incompatible types: org.apache.flink.storm.split.operators.VerifyAndEnrichBolt cannot be converted to backtype.storm.topology.IRichBolt [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/wordcount/SpoutSourceWordCount.java:[142,41] no suitable constructor found for SpoutWrapper(org.apache.flink.storm.wordcount.operators.WordCountFileSpout,java.lang.String[],int) constructor org.apache.flink.storm.wrappers.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpout,java.lang.String[],java.lang.Integer) is not applicable (argument mismatch; org.apache.flink.storm.wordcount.operators.WordCountFileSpout cannot be converted to backtype.storm.topology.IRichSpout) constructor org.apache.flink.storm.wrappers.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpout,java.util.Collection<java.lang.String>,java.lang.Integer) is not applicable (argument mismatch; org.apache.flink.storm.wordcount.operators.WordCountFileSpout cannot be converted to backtype.storm.topology.IRichSpout) [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/wordcount/SpoutSourceWordCount.java:[148,33] no suitable constructor found for SpoutWrapper(org.apache.flink.storm.wordcount.operators.WordCountInMemorySpout,java.lang.String[],int) constructor org.apache.flink.storm.wrappers.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpout,java.lang.String[],java.lang.Integer) is not applicable (argument mismatch; org.apache.flink.storm.wordcount.operators.WordCountInMemorySpout cannot be converted to backtype.storm.topology.IRichSpout) constructor org.apache.flink.storm.wrappers.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpout,java.util.Collection<java.lang.String>,java.lang.Integer) is not applicable (argument mismatch; org.apache.flink.storm.wordcount.operators.WordCountInMemorySpout cannot be converted to backtype.storm.topology.IRichSpout) [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/wordcount/WordCountLocal.java:[66,87] incompatible types: org.apache.storm.topology.TopologyBuilder cannot be converted to backtype.storm.topology.TopologyBuilder [INFO] 24 errors [INFO] ------------------------------------------------------------- [INFO] ------------------------------------------------------------------------ [INFO] BUILD FAILURE [INFO] ------------------------------------------------------------------------ [INFO] Total time: 8.537 s [INFO] Finished at: 2017-02-22T10:35:35-08:00 [INFO] Final Memory: 48M/358M [INFO] ------------------------------------------------------------------------ [ERROR] Failed to execute goal org.apache.maven.plugins:maven-compiler-plugin:3.1:compile (default-compile) on project flink-storm-examples_2.10: Compilation failure: Compilation failure: [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/util/FiniteInMemorySpout.java:[25,8] cannot access backtype.storm.topology.IRichSpout [ERROR] class file for backtype.storm.topology.IRichSpout not found [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/exclamation/ExclamationWithBolt.java:[73,49] cannot access backtype.storm.topology.IRichBolt [ERROR] class file for backtype.storm.topology.IRichBolt not found [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/join/SingleJoinExample.java:[47,88] incompatible types: org.apache.storm.testing.FeederSpout cannot be converted to backtype.storm.topology.IRichSpout [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/join/SingleJoinExample.java:[48,86] incompatible types: org.apache.storm.testing.FeederSpout cannot be converted to backtype.storm.topology.IRichSpout [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/join/SingleJoinExample.java:[50,44] incompatible types: org.apache.flink.storm.util.NullTerminatingSpout cannot be converted to org.apache.storm.topology.IRichSpout [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/join/SingleJoinExample.java:[51,41] incompatible types: org.apache.flink.storm.util.NullTerminatingSpout cannot be converted to org.apache.storm.topology.IRichSpout [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/join/SingleJoinExample.java:[84,75] cannot access backtype.storm.topology.TopologyBuilder [ERROR] class file for backtype.storm.topology.TopologyBuilder not found [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/util/FiniteInMemorySpout.java:[32,9] method does not override or implement a method from a supertype [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/wordcount/WordCountTopology.java:[73,76] incompatible types: org.apache.flink.storm.wordcount.operators.WordCountFileSpout cannot be converted to backtype.storm.topology.IRichSpout [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/exclamation/ExclamationLocal.java:[68,87] incompatible types: org.apache.storm.topology.TopologyBuilder cannot be converted to backtype.storm.topology.TopologyBuilder [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/print/PrintSampleStream.java:[63,84] incompatible types: org.apache.storm.topology.TopologyBuilder cannot be converted to backtype.storm.topology.TopologyBuilder [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/wordcount/WordCountLocalByName.java:[67,87] incompatible types: org.apache.storm.topology.TopologyBuilder cannot be converted to backtype.storm.topology.TopologyBuilder [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/wordcount/BoltTokenizerWordCountPojo.java:[73,100] incompatible types: org.apache.flink.storm.wordcount.operators.BoltTokenizerByName cannot be converted to backtype.storm.topology.IRichBolt [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/wordcount/WordCountRemoteBySubmitter.java:[75,94] incompatible types: org.apache.storm.topology.TopologyBuilder cannot be converted to backtype.storm.topology.TopologyBuilder [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/wordcount/WordCountRemoteByClient.java:[77,102] incompatible types: org.apache.storm.topology.TopologyBuilder cannot be converted to backtype.storm.topology.TopologyBuilder [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/wordcount/BoltTokenizerWordCountWithNames.java:[76,49] no suitable constructor found for BoltWrapper(org.apache.flink.storm.wordcount.operators.BoltTokenizerByName,org.apache.storm.tuple.Fields) [ERROR] constructor org.apache.flink.storm.wrappers.BoltWrapper.BoltWrapper(backtype.storm.topology.IRichBolt,backtype.storm.tuple.Fields) is not applicable [ERROR] (argument mismatch; org.apache.flink.storm.wordcount.operators.BoltTokenizerByName cannot be converted to backtype.storm.topology.IRichBolt) [ERROR] constructor org.apache.flink.storm.wrappers.BoltWrapper.BoltWrapper(backtype.storm.topology.IRichBolt,java.lang.String[]) is not applicable [ERROR] (argument mismatch; org.apache.flink.storm.wordcount.operators.BoltTokenizerByName cannot be converted to backtype.storm.topology.IRichBolt) [ERROR] constructor org.apache.flink.storm.wrappers.BoltWrapper.BoltWrapper(backtype.storm.topology.IRichBolt,java.util.Collection<java.lang.String>) is not applicable [ERROR] (argument mismatch; org.apache.flink.storm.wordcount.operators.BoltTokenizerByName cannot be converted to backtype.storm.topology.IRichBolt) [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/exclamation/ExclamationWithSpout.java:[134,41] no suitable constructor found for SpoutWrapper(org.apache.flink.storm.util.FiniteFileSpout,java.lang.String[]) [ERROR] constructor org.apache.flink.storm.wrappers.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpout,java.lang.Integer) is not applicable [ERROR] (argument mismatch; org.apache.flink.storm.util.FiniteFileSpout cannot be converted to backtype.storm.topology.IRichSpout) [ERROR] constructor org.apache.flink.storm.wrappers.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpout,java.lang.String[]) is not applicable [ERROR] (argument mismatch; org.apache.flink.storm.util.FiniteFileSpout cannot be converted to backtype.storm.topology.IRichSpout) [ERROR] constructor org.apache.flink.storm.wrappers.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpout,java.util.Collection<java.lang.String>) is not applicable [ERROR] (argument mismatch; org.apache.flink.storm.util.FiniteFileSpout cannot be converted to backtype.storm.topology.IRichSpout) [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/exclamation/ExclamationWithSpout.java:[140,33] no suitable constructor found for SpoutWrapper(org.apache.flink.storm.util.FiniteInMemorySpout,java.lang.String[]) [ERROR] constructor org.apache.flink.storm.wrappers.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpout,java.lang.Integer) is not applicable [ERROR] (argument mismatch; org.apache.flink.storm.util.FiniteInMemorySpout cannot be converted to backtype.storm.topology.IRichSpout) [ERROR] constructor org.apache.flink.storm.wrappers.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpout,java.lang.String[]) is not applicable [ERROR] (argument mismatch; org.apache.flink.storm.util.FiniteInMemorySpout cannot be converted to backtype.storm.topology.IRichSpout) [ERROR] constructor org.apache.flink.storm.wrappers.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpout,java.util.Collection<java.lang.String>) is not applicable [ERROR] (argument mismatch; org.apache.flink.storm.util.FiniteInMemorySpout cannot be converted to backtype.storm.topology.IRichSpout) [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/wordcount/BoltTokenizerWordCount.java:[66,98] incompatible types: org.apache.flink.storm.wordcount.operators.BoltTokenizer cannot be converted to backtype.storm.topology.IRichBolt [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/split/SpoutSplitExample.java:[62,33] no suitable constructor found for SpoutWrapper(org.apache.flink.storm.split.operators.RandomSpout,java.lang.String[],int) [ERROR] constructor org.apache.flink.storm.wrappers.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpout,java.lang.String[],java.lang.Integer) is not applicable [ERROR] (argument mismatch; org.apache.flink.storm.split.operators.RandomSpout cannot be converted to backtype.storm.topology.IRichSpout) [ERROR] constructor org.apache.flink.storm.wrappers.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpout,java.util.Collection<java.lang.String>,java.lang.Integer) is not applicable [ERROR] (argument mismatch; org.apache.flink.storm.split.operators.RandomSpout cannot be converted to backtype.storm.topology.IRichSpout) [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/split/SpoutSplitExample.java:[76,99] incompatible types: org.apache.flink.storm.split.operators.VerifyAndEnrichBolt cannot be converted to backtype.storm.topology.IRichBolt [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/wordcount/SpoutSourceWordCount.java:[142,41] no suitable constructor found for SpoutWrapper(org.apache.flink.storm.wordcount.operators.WordCountFileSpout,java.lang.String[],int) [ERROR] constructor org.apache.flink.storm.wrappers.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpout,java.lang.String[],java.lang.Integer) is not applicable [ERROR] (argument mismatch; org.apache.flink.storm.wordcount.operators.WordCountFileSpout cannot be converted to backtype.storm.topology.IRichSpout) [ERROR] constructor org.apache.flink.storm.wrappers.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpout,java.util.Collection<java.lang.String>,java.lang.Integer) is not applicable [ERROR] (argument mismatch; org.apache.flink.storm.wordcount.operators.WordCountFileSpout cannot be converted to backtype.storm.topology.IRichSpout) [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/wordcount/SpoutSourceWordCount.java:[148,33] no suitable constructor found for SpoutWrapper(org.apache.flink.storm.wordcount.operators.WordCountInMemorySpout,java.lang.String[],int) [ERROR] constructor org.apache.flink.storm.wrappers.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpout,java.lang.String[],java.lang.Integer) is not applicable [ERROR] (argument mismatch; org.apache.flink.storm.wordcount.operators.WordCountInMemorySpout cannot be converted to backtype.storm.topology.IRichSpout) [ERROR] constructor org.apache.flink.storm.wrappers.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpout,java.util.Collection<java.lang.String>,java.lang.Integer) is not applicable [ERROR] (argument mismatch; org.apache.flink.storm.wordcount.operators.WordCountInMemorySpout cannot be converted to backtype.storm.topology.IRichSpout) [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/wordcount/WordCountLocal.java:[66,87] incompatible types: org.apache.storm.topology.TopologyBuilder cannot be converted to backtype.storm.topology.TopologyBuilder [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: lior@MacBook-Pro-2 ~/src/flink/flink/flink-contrib/flink-storm-examples (pm/lior/py_tests) $ On Wed, Feb 22, 2017 at 10:33 AM, Ted Yu <[hidden email]> wrote:
|
|
|
Which commit is your local repo ? As of commit b0f0f3722fac4726fba879736c7ee85993b392db , I don't see IRichSpout in flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/util/FiniteInMemorySpout.java Don't know where the backtype came from On Wed, Feb 22, 2017 at 10:36 AM, Lior Amar <[hidden email]> wrote:
|
|
|
Here is my commit path * 59ba32e - (HEAD -> pm/lior/py_tests, pm/pm/lior/py_tests) python: adding the --list-tests and --mvn-mode flags. (2 hours ago) <Lior Amar> * e640894 - python: clearing the arguments StringBuilder so it can be called multiple times with different args (2 hours ago) <Lior Amar> * 2619fb9 - python: renaming test_pyflink.py -> ut_pyflink.py (2 hours ago) <Lior Amar> * 8f40ef1 - python: Adding PythonPlanBinderUnitTest.java to run unittest like files (2 hours ago) <Lior Amar> * aae7668 - python: changing the PythonPlanBinder.java auto-detected files (2 hours ago) <Lior Amar> * a7a2585 - python: adding .gitignore to ignore *.pyc files. (2 hours ago) <Lior Amar> * 039772e - pyflink: add Environment.from_list() method (2 hours ago) <Lior Amar> * e8eb080 - pytests: helper script to run tests (2 hours ago) <Lior Amar> * 5d0317a - pytest: adding test_pyflink.py which runs the Flink Python batch tests in a unittests style (2 hours ago) <Lior Amar> * 71e434c - pytest: adding a subprocess test module to run test in external process (2 hours ago) <Lior Amar> * a1e6df1 - fix: fixing start-cluster.sh to propagate FLINK_CONF_DIR correctly. (2 hours ago) <Lior Amar> * d6aed38 - (pm/master, origin/master, origin/HEAD, master) [FLINK-5836] [flip6] Fix race condition between offer slot and submit task (5 hours ago) <wenlong.lwl> I am on d6aed38. (btw - on linux there is no issue) On Wed, Feb 22, 2017 at 10:50 AM, Ted Yu <[hidden email]> wrote:
|
|
|
commit d6aed38b3a15946d383d762030b5f5c1418388de Author: wenlong.lwl <[hidden email]> Date: Fri Jan 6 16:32:08 2017 +0800 Can you update your local workspace and try again ? On Wed, Feb 22, 2017 at 10:53 AM, Lior Amar <[hidden email]> wrote:
|
|
|
Problem solved, thanks. git fetch and rebased my master on the origin/master then rebased my local branch on master... so now it looks like: * 9ab0faa - (HEAD -> pm/lior/py_tests) python: adding the --list-tests and --mvn-mode flags. (2 minutes ago) <Lior Amar> * d2cab93 - python: clearing the arguments StringBuilder so it can be called multiple times with different args (2 minutes ago) <Lior Amar> * 7cbd90f - python: renaming test_pyflink.py -> ut_pyflink.py (2 minutes ago) <Lior Amar> * b0a3dc6 - python: Adding PythonPlanBinderUnitTest.java to run unittest like files (2 minutes ago) <Lior Amar> * 6dade69 - python: changing the PythonPlanBinder.java auto-detected files (2 minutes ago) <Lior Amar> * 4a57f46 - python: adding .gitignore to ignore *.pyc files. (2 minutes ago) <Lior Amar> * 920326e - pyflink: add Environment.from_list() method (2 minutes ago) <Lior Amar> * 5462d59 - pytests: helper script to run tests (2 minutes ago) <Lior Amar> * 240467d - pytest: adding test_pyflink.py which runs the Flink Python batch tests in a unittests style (2 minutes ago) <Lior Amar> * 3ccc561 - pytest: adding a subprocess test module to run test in external process (2 minutes ago) <Lior Amar> * 0947656 - fix: fixing start-cluster.sh to propagate FLINK_CONF_DIR correctly. (2 minutes ago) <Lior Amar> * b0f0f37 - (origin/master, origin/HEAD, master) [FLINK-5716] [streaming] Make StreamSourceContexts aware of source idleness (2 hours ago) <Tzu-Li (Gordon) Tai> * 646490c - [FLINK-5701] [kafka] FlinkKafkaProducer should check asyncException on checkpoints (2 hours ago) <Tzu-Li (Gordon) Tai> * d6aed38 - (pm/master) [FLINK-5836] [flip6] Fix race condition between offer slot and submit task (6 hours ago) <wenlong.lwl> * 8e1775a - [FLINK-5876] [docs] Mention Scala extensions in queryable state docs (6 hours ago) <Ufuk Celebi> Then I did the following: mvn clean inside flink-storm-examples mvn install inside flink-storm-examples Seems to work now. Thanks. On Wed, Feb 22, 2017 at 10:55 AM, Ted Yu <[hidden email]> wrote:
|
«
Return to (DEPRECATED) Apache Flink User Mailing List archive.
|
1 view|%1 views
| Free forum by Nabble | Edit this page |