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.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
>>
>
>
