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 <lior.a...@parallelmachines.com> 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: > [ERROR] [Help 1] http://cwiki.apache.org/confluence/display/MAVEN/ > MojoFailureException > 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 <yuzhih...@gmail.com> wrote: > >> 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 < >> lior.a...@parallelmachines.com> wrote: >> >>> 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 >>> >> >> >
