flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ted Yu <yuzhih...@gmail.com>
Subject Re: Compiling Flink on macOS.
Date Wed, 22 Feb 2017 18:50:31 GMT
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.amar@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 <yuzhihong@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.amar@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
>>>
>>
>>
>

Mime
View raw message