You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Lior Amar <li...@parallelmachines.com> on 2017/02/22 18:24:58 UTC
Compiling Flink on macOS.
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
Re: Compiling Flink on macOS.
Posted by Lior Amar <li...@parallelmachines.com>.
Problem solved, thanks.
I did the following steps.
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 <yu...@gmail.com> wrote:
> commit d6aed38b3a15946d383d762030b5f5c1418388de
> Author: wenlong.lwl <we...@alibaba-inc.com>
> 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 <lior.amar@parallelmachines.
> com> 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 <yu...@gmail.com> 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/apac
>>> he/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-exampl
>>>> es/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/fl
>>>> ink-contrib/flink-storm-examples/target/classes
>>>> [INFO] -------------------------------------------------------------
>>>> [WARNING] COMPILATION WARNING :
>>>> [INFO] -------------------------------------------------------------
>>>> [WARNING] /Users/lior/src/flink/flink/flink-contrib/flink-storm-exampl
>>>> es/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-exampl
>>>> es/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-exampl
>>>> es/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-exampl
>>>> es/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-exampl
>>>> es/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-exampl
>>>> es/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-exampl
>>>> es/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-exampl
>>>> es/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-exampl
>>>> es/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-exampl
>>>> es/src/main/java/org/apache/flink/storm/wordcount/WordCountTopology.java:[73,76]
>>>> incompatible types: org.apache.flink.storm.wordcou
>>>> nt.operators.WordCountFileSpout cannot be converted to
>>>> backtype.storm.topology.IRichSpout
>>>> [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-exampl
>>>> es/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-exampl
>>>> es/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-exampl
>>>> es/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-exampl
>>>> es/src/main/java/org/apache/flink/storm/wordcount/BoltTokenizerWordCountPojo.java:[73,100]
>>>> incompatible types: org.apache.flink.storm.wordcou
>>>> nt.operators.BoltTokenizerByName cannot be converted to
>>>> backtype.storm.topology.IRichBolt
>>>> [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-exampl
>>>> es/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-exampl
>>>> es/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-exampl
>>>> es/src/main/java/org/apache/flink/storm/wordcount/BoltTokeni
>>>> zerWordCountWithNames.java:[76,49] no suitable constructor found for
>>>> BoltWrapper(org.apache.flink.storm.wordcount.operators.BoltT
>>>> okenizerByName,org.apache.storm.tuple.Fields)
>>>> constructor org.apache.flink.storm.wrapper
>>>> s.BoltWrapper.BoltWrapper(backtype.storm.topology.IRichBolt,backtype.storm.tuple.Fields)
>>>> is not applicable
>>>> (argument mismatch; org.apache.flink.storm.wordcou
>>>> nt.operators.BoltTokenizerByName cannot be converted to
>>>> backtype.storm.topology.IRichBolt)
>>>> constructor org.apache.flink.storm.wrapper
>>>> s.BoltWrapper.BoltWrapper(backtype.storm.topology.IRichBolt,java.lang.String[])
>>>> is not applicable
>>>> (argument mismatch; org.apache.flink.storm.wordcou
>>>> nt.operators.BoltTokenizerByName cannot be converted to
>>>> backtype.storm.topology.IRichBolt)
>>>> constructor org.apache.flink.storm.wrapper
>>>> s.BoltWrapper.BoltWrapper(backtype.storm.topology.IRichBolt,
>>>> java.util.Collection<java.lang.String>) is not applicable
>>>> (argument mismatch; org.apache.flink.storm.wordcou
>>>> nt.operators.BoltTokenizerByName cannot be converted to
>>>> backtype.storm.topology.IRichBolt)
>>>> [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-exampl
>>>> es/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.wrapper
>>>> s.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.wrapper
>>>> s.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.wrapper
>>>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpo
>>>> ut,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-exampl
>>>> es/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.wrapper
>>>> s.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.wrapper
>>>> s.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.wrapper
>>>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpo
>>>> ut,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-exampl
>>>> es/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-exampl
>>>> es/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.wrapper
>>>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpo
>>>> ut,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.wrapper
>>>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpo
>>>> ut,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-exampl
>>>> es/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-exampl
>>>> es/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.wrapper
>>>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpo
>>>> ut,java.lang.String[],java.lang.Integer) is not applicable
>>>> (argument mismatch; org.apache.flink.storm.wordcou
>>>> nt.operators.WordCountFileSpout cannot be converted to
>>>> backtype.storm.topology.IRichSpout)
>>>> constructor org.apache.flink.storm.wrapper
>>>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpo
>>>> ut,java.util.Collection<java.lang.String>,java.lang.Integer) is not
>>>> applicable
>>>> (argument mismatch; org.apache.flink.storm.wordcou
>>>> nt.operators.WordCountFileSpout cannot be converted to
>>>> backtype.storm.topology.IRichSpout)
>>>> [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-exampl
>>>> es/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.S
>>>> tring[],int)
>>>> constructor org.apache.flink.storm.wrapper
>>>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpo
>>>> ut,java.lang.String[],java.lang.Integer) is not applicable
>>>> (argument mismatch; org.apache.flink.storm.wordcou
>>>> nt.operators.WordCountInMemorySpout cannot be converted to
>>>> backtype.storm.topology.IRichSpout)
>>>> constructor org.apache.flink.storm.wrapper
>>>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpo
>>>> ut,java.util.Collection<java.lang.String>,java.lang.Integer) is not
>>>> applicable
>>>> (argument mismatch; org.apache.flink.storm.wordcou
>>>> nt.operators.WordCountInMemorySpout cannot be converted to
>>>> backtype.storm.topology.IRichSpout)
>>>> [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-exampl
>>>> es/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-exampl
>>>> es/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-exampl
>>>> es/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-exampl
>>>> es/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-exampl
>>>> es/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-exampl
>>>> es/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-exampl
>>>> es/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-exampl
>>>> es/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-exampl
>>>> es/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-exampl
>>>> es/src/main/java/org/apache/flink/storm/wordcount/WordCountTopology.java:[73,76]
>>>> incompatible types: org.apache.flink.storm.wordcou
>>>> nt.operators.WordCountFileSpout cannot be converted to
>>>> backtype.storm.topology.IRichSpout
>>>> [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-exampl
>>>> es/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-exampl
>>>> es/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-exampl
>>>> es/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-exampl
>>>> es/src/main/java/org/apache/flink/storm/wordcount/BoltTokenizerWordCountPojo.java:[73,100]
>>>> incompatible types: org.apache.flink.storm.wordcou
>>>> nt.operators.BoltTokenizerByName cannot be converted to
>>>> backtype.storm.topology.IRichBolt
>>>> [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-exampl
>>>> es/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-exampl
>>>> es/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-exampl
>>>> es/src/main/java/org/apache/flink/storm/wordcount/BoltTokeni
>>>> zerWordCountWithNames.java:[76,49] no suitable constructor found for
>>>> BoltWrapper(org.apache.flink.storm.wordcount.operators.BoltT
>>>> okenizerByName,org.apache.storm.tuple.Fields)
>>>> [ERROR] constructor org.apache.flink.storm.wrapper
>>>> s.BoltWrapper.BoltWrapper(backtype.storm.topology.IRichBolt,backtype.storm.tuple.Fields)
>>>> is not applicable
>>>> [ERROR] (argument mismatch; org.apache.flink.storm.wordcou
>>>> nt.operators.BoltTokenizerByName cannot be converted to
>>>> backtype.storm.topology.IRichBolt)
>>>> [ERROR] constructor org.apache.flink.storm.wrapper
>>>> s.BoltWrapper.BoltWrapper(backtype.storm.topology.IRichBolt,java.lang.String[])
>>>> is not applicable
>>>> [ERROR] (argument mismatch; org.apache.flink.storm.wordcou
>>>> nt.operators.BoltTokenizerByName cannot be converted to
>>>> backtype.storm.topology.IRichBolt)
>>>> [ERROR] constructor org.apache.flink.storm.wrapper
>>>> s.BoltWrapper.BoltWrapper(backtype.storm.topology.IRichBolt,
>>>> java.util.Collection<java.lang.String>) is not applicable
>>>> [ERROR] (argument mismatch; org.apache.flink.storm.wordcou
>>>> nt.operators.BoltTokenizerByName cannot be converted to
>>>> backtype.storm.topology.IRichBolt)
>>>> [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-exampl
>>>> es/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.wrapper
>>>> s.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.wrapper
>>>> s.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.wrapper
>>>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpo
>>>> ut,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-exampl
>>>> es/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.wrapper
>>>> s.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.wrapper
>>>> s.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.wrapper
>>>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpo
>>>> ut,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-exampl
>>>> es/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-exampl
>>>> es/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.wrapper
>>>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpo
>>>> ut,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.wrapper
>>>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpo
>>>> ut,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-exampl
>>>> es/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-exampl
>>>> es/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.wrapper
>>>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpo
>>>> ut,java.lang.String[],java.lang.Integer) is not applicable
>>>> [ERROR] (argument mismatch; org.apache.flink.storm.wordcou
>>>> nt.operators.WordCountFileSpout cannot be converted to
>>>> backtype.storm.topology.IRichSpout)
>>>> [ERROR] constructor org.apache.flink.storm.wrapper
>>>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpo
>>>> ut,java.util.Collection<java.lang.String>,java.lang.Integer) is not
>>>> applicable
>>>> [ERROR] (argument mismatch; org.apache.flink.storm.wordcou
>>>> nt.operators.WordCountFileSpout cannot be converted to
>>>> backtype.storm.topology.IRichSpout)
>>>> [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-exampl
>>>> es/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.S
>>>> tring[],int)
>>>> [ERROR] constructor org.apache.flink.storm.wrapper
>>>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpo
>>>> ut,java.lang.String[],java.lang.Integer) is not applicable
>>>> [ERROR] (argument mismatch; org.apache.flink.storm.wordcou
>>>> nt.operators.WordCountInMemorySpout cannot be converted to
>>>> backtype.storm.topology.IRichSpout)
>>>> [ERROR] constructor org.apache.flink.storm.wrapper
>>>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpo
>>>> ut,java.util.Collection<java.lang.String>,java.lang.Integer) is not
>>>> applicable
>>>> [ERROR] (argument mismatch; org.apache.flink.storm.wordcou
>>>> nt.operators.WordCountInMemorySpout cannot be converted to
>>>> backtype.storm.topology.IRichSpout)
>>>> [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-exampl
>>>> es/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/conflu
>>>> ence/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 <yu...@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
>>>>>>
>>>>>
>>>>>
>>>>
>>>
>>
>
Re: Compiling Flink on macOS.
Posted by Ted Yu <yu...@gmail.com>.
commit d6aed38b3a15946d383d762030b5f5c1418388de
Author: wenlong.lwl <we...@alibaba-inc.com>
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 <li...@parallelmachines.com>
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 <yu...@gmail.com> 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/apac
>> he/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/fl
>>> ink-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/fl
>>> ink-contrib/flink-storm-examples/target/classes
>>> [INFO] -------------------------------------------------------------
>>> [WARNING] COMPILATION WARNING :
>>> [INFO] -------------------------------------------------------------
>>> [WARNING] /Users/lior/src/flink/flink/flink-contrib/flink-storm-exampl
>>> es/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-exampl
>>> es/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-exampl
>>> es/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-exampl
>>> es/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-exampl
>>> es/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-exampl
>>> es/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-exampl
>>> es/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-exampl
>>> es/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-exampl
>>> es/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-exampl
>>> es/src/main/java/org/apache/flink/storm/wordcount/WordCountTopology.java:[73,76]
>>> incompatible types: org.apache.flink.storm.wordcou
>>> nt.operators.WordCountFileSpout cannot be converted to
>>> backtype.storm.topology.IRichSpout
>>> [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-exampl
>>> es/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-exampl
>>> es/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-exampl
>>> es/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-exampl
>>> es/src/main/java/org/apache/flink/storm/wordcount/BoltTokenizerWordCountPojo.java:[73,100]
>>> incompatible types: org.apache.flink.storm.wordcou
>>> nt.operators.BoltTokenizerByName cannot be converted to
>>> backtype.storm.topology.IRichBolt
>>> [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-exampl
>>> es/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-exampl
>>> es/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-exampl
>>> es/src/main/java/org/apache/flink/storm/wordcount/BoltTokeni
>>> zerWordCountWithNames.java:[76,49] no suitable constructor found for
>>> BoltWrapper(org.apache.flink.storm.wordcount.operators.BoltT
>>> okenizerByName,org.apache.storm.tuple.Fields)
>>> constructor org.apache.flink.storm.wrapper
>>> s.BoltWrapper.BoltWrapper(backtype.storm.topology.IRichBolt,backtype.storm.tuple.Fields)
>>> is not applicable
>>> (argument mismatch; org.apache.flink.storm.wordcou
>>> nt.operators.BoltTokenizerByName cannot be converted to
>>> backtype.storm.topology.IRichBolt)
>>> constructor org.apache.flink.storm.wrapper
>>> s.BoltWrapper.BoltWrapper(backtype.storm.topology.IRichBolt,java.lang.String[])
>>> is not applicable
>>> (argument mismatch; org.apache.flink.storm.wordcou
>>> nt.operators.BoltTokenizerByName cannot be converted to
>>> backtype.storm.topology.IRichBolt)
>>> constructor org.apache.flink.storm.wrapper
>>> s.BoltWrapper.BoltWrapper(backtype.storm.topology.IRichBolt,
>>> java.util.Collection<java.lang.String>) is not applicable
>>> (argument mismatch; org.apache.flink.storm.wordcou
>>> nt.operators.BoltTokenizerByName cannot be converted to
>>> backtype.storm.topology.IRichBolt)
>>> [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-exampl
>>> es/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.wrapper
>>> s.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.wrapper
>>> s.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.wrapper
>>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpo
>>> ut,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-exampl
>>> es/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.wrapper
>>> s.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.wrapper
>>> s.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.wrapper
>>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpo
>>> ut,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-exampl
>>> es/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-exampl
>>> es/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.wrapper
>>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpo
>>> ut,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.wrapper
>>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpo
>>> ut,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-exampl
>>> es/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-exampl
>>> es/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.wrapper
>>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpo
>>> ut,java.lang.String[],java.lang.Integer) is not applicable
>>> (argument mismatch; org.apache.flink.storm.wordcou
>>> nt.operators.WordCountFileSpout cannot be converted to
>>> backtype.storm.topology.IRichSpout)
>>> constructor org.apache.flink.storm.wrapper
>>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpo
>>> ut,java.util.Collection<java.lang.String>,java.lang.Integer) is not
>>> applicable
>>> (argument mismatch; org.apache.flink.storm.wordcou
>>> nt.operators.WordCountFileSpout cannot be converted to
>>> backtype.storm.topology.IRichSpout)
>>> [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-exampl
>>> es/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.wrapper
>>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpo
>>> ut,java.lang.String[],java.lang.Integer) is not applicable
>>> (argument mismatch; org.apache.flink.storm.wordcou
>>> nt.operators.WordCountInMemorySpout cannot be converted to
>>> backtype.storm.topology.IRichSpout)
>>> constructor org.apache.flink.storm.wrapper
>>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpo
>>> ut,java.util.Collection<java.lang.String>,java.lang.Integer) is not
>>> applicable
>>> (argument mismatch; org.apache.flink.storm.wordcou
>>> nt.operators.WordCountInMemorySpout cannot be converted to
>>> backtype.storm.topology.IRichSpout)
>>> [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-exampl
>>> es/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-exampl
>>> es/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-exampl
>>> es/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-exampl
>>> es/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-exampl
>>> es/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-exampl
>>> es/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-exampl
>>> es/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-exampl
>>> es/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-exampl
>>> es/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-exampl
>>> es/src/main/java/org/apache/flink/storm/wordcount/WordCountTopology.java:[73,76]
>>> incompatible types: org.apache.flink.storm.wordcou
>>> nt.operators.WordCountFileSpout cannot be converted to
>>> backtype.storm.topology.IRichSpout
>>> [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-exampl
>>> es/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-exampl
>>> es/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-exampl
>>> es/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-exampl
>>> es/src/main/java/org/apache/flink/storm/wordcount/BoltTokenizerWordCountPojo.java:[73,100]
>>> incompatible types: org.apache.flink.storm.wordcou
>>> nt.operators.BoltTokenizerByName cannot be converted to
>>> backtype.storm.topology.IRichBolt
>>> [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-exampl
>>> es/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-exampl
>>> es/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-exampl
>>> es/src/main/java/org/apache/flink/storm/wordcount/BoltTokeni
>>> zerWordCountWithNames.java:[76,49] no suitable constructor found for
>>> BoltWrapper(org.apache.flink.storm.wordcount.operators.BoltT
>>> okenizerByName,org.apache.storm.tuple.Fields)
>>> [ERROR] constructor org.apache.flink.storm.wrapper
>>> s.BoltWrapper.BoltWrapper(backtype.storm.topology.IRichBolt,backtype.storm.tuple.Fields)
>>> is not applicable
>>> [ERROR] (argument mismatch; org.apache.flink.storm.wordcou
>>> nt.operators.BoltTokenizerByName cannot be converted to
>>> backtype.storm.topology.IRichBolt)
>>> [ERROR] constructor org.apache.flink.storm.wrapper
>>> s.BoltWrapper.BoltWrapper(backtype.storm.topology.IRichBolt,java.lang.String[])
>>> is not applicable
>>> [ERROR] (argument mismatch; org.apache.flink.storm.wordcou
>>> nt.operators.BoltTokenizerByName cannot be converted to
>>> backtype.storm.topology.IRichBolt)
>>> [ERROR] constructor org.apache.flink.storm.wrapper
>>> s.BoltWrapper.BoltWrapper(backtype.storm.topology.IRichBolt,
>>> java.util.Collection<java.lang.String>) is not applicable
>>> [ERROR] (argument mismatch; org.apache.flink.storm.wordcou
>>> nt.operators.BoltTokenizerByName cannot be converted to
>>> backtype.storm.topology.IRichBolt)
>>> [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-exampl
>>> es/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.wrapper
>>> s.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.wrapper
>>> s.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.wrapper
>>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpo
>>> ut,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-exampl
>>> es/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.wrapper
>>> s.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.wrapper
>>> s.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.wrapper
>>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpo
>>> ut,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-exampl
>>> es/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-exampl
>>> es/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.wrapper
>>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpo
>>> ut,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.wrapper
>>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpo
>>> ut,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-exampl
>>> es/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-exampl
>>> es/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.wrapper
>>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpo
>>> ut,java.lang.String[],java.lang.Integer) is not applicable
>>> [ERROR] (argument mismatch; org.apache.flink.storm.wordcou
>>> nt.operators.WordCountFileSpout cannot be converted to
>>> backtype.storm.topology.IRichSpout)
>>> [ERROR] constructor org.apache.flink.storm.wrapper
>>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpo
>>> ut,java.util.Collection<java.lang.String>,java.lang.Integer) is not
>>> applicable
>>> [ERROR] (argument mismatch; org.apache.flink.storm.wordcou
>>> nt.operators.WordCountFileSpout cannot be converted to
>>> backtype.storm.topology.IRichSpout)
>>> [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-exampl
>>> es/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.wrapper
>>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpo
>>> ut,java.lang.String[],java.lang.Integer) is not applicable
>>> [ERROR] (argument mismatch; org.apache.flink.storm.wordcou
>>> nt.operators.WordCountInMemorySpout cannot be converted to
>>> backtype.storm.topology.IRichSpout)
>>> [ERROR] constructor org.apache.flink.storm.wrapper
>>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.IRichSpo
>>> ut,java.util.Collection<java.lang.String>,java.lang.Integer) is not
>>> applicable
>>> [ERROR] (argument mismatch; org.apache.flink.storm.wordcou
>>> nt.operators.WordCountInMemorySpout cannot be converted to
>>> backtype.storm.topology.IRichSpout)
>>> [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-exampl
>>> es/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/conflu
>>> ence/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 <yu...@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
>>>>>
>>>>
>>>>
>>>
>>
>
Re: Compiling Flink on macOS.
Posted by Lior Amar <li...@parallelmachines.com>.
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 <yu...@gmail.com> 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 <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/fl
>> ink-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/fl
>> ink-contrib/flink-storm-examples/target/classes
>> [INFO] -------------------------------------------------------------
>> [WARNING] COMPILATION WARNING :
>> [INFO] -------------------------------------------------------------
>> [WARNING] /Users/lior/src/flink/flink/flink-contrib/flink-storm-exampl
>> es/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-exampl
>> es/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-exampl
>> es/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-exampl
>> es/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-exampl
>> es/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-exampl
>> es/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-exampl
>> es/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-exampl
>> es/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-exampl
>> es/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-exampl
>> es/src/main/java/org/apache/flink/storm/wordcount/WordCountTopology.java:[73,76]
>> incompatible types: org.apache.flink.storm.wordcou
>> nt.operators.WordCountFileSpout cannot be converted to
>> backtype.storm.topology.IRichSpout
>> [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-exampl
>> es/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-exampl
>> es/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-exampl
>> es/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-exampl
>> es/src/main/java/org/apache/flink/storm/wordcount/BoltToke
>> nizerWordCountPojo.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-exampl
>> es/src/main/java/org/apache/flink/storm/wordcount/WordCoun
>> tRemoteBySubmitter.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-exampl
>> es/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-exampl
>> es/src/main/java/org/apache/flink/storm/wordcount/BoltToke
>> nizerWordCountWithNames.java:[76,49] no suitable constructor found for
>> BoltWrapper(org.apache.flink.storm.wordcount.operators.BoltT
>> okenizerByName,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.wordcou
>> nt.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.wordcou
>> nt.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.wordcou
>> nt.operators.BoltTokenizerByName cannot be converted to
>> backtype.storm.topology.IRichBolt)
>> [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-exampl
>> es/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.wrapper
>> s.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.wrapper
>> s.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.wrapper
>> s.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-exampl
>> es/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.wrapper
>> s.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.wrapper
>> s.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.wrapper
>> s.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-exampl
>> es/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-exampl
>> es/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.wrapper
>> s.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.wrapper
>> s.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-exampl
>> es/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-exampl
>> es/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.wrapper
>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.
>> IRichSpout,java.lang.String[],java.lang.Integer) is not applicable
>> (argument mismatch; org.apache.flink.storm.wordcou
>> nt.operators.WordCountFileSpout cannot be converted to
>> backtype.storm.topology.IRichSpout)
>> constructor org.apache.flink.storm.wrapper
>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.
>> IRichSpout,java.util.Collection<java.lang.String>,java.lang.Integer) is
>> not applicable
>> (argument mismatch; org.apache.flink.storm.wordcou
>> nt.operators.WordCountFileSpout cannot be converted to
>> backtype.storm.topology.IRichSpout)
>> [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-exampl
>> es/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.wrapper
>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.
>> IRichSpout,java.lang.String[],java.lang.Integer) is not applicable
>> (argument mismatch; org.apache.flink.storm.wordcou
>> nt.operators.WordCountInMemorySpout cannot be converted to
>> backtype.storm.topology.IRichSpout)
>> constructor org.apache.flink.storm.wrapper
>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.
>> IRichSpout,java.util.Collection<java.lang.String>,java.lang.Integer) is
>> not applicable
>> (argument mismatch; org.apache.flink.storm.wordcou
>> nt.operators.WordCountInMemorySpout cannot be converted to
>> backtype.storm.topology.IRichSpout)
>> [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-exampl
>> es/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-exampl
>> es/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-exampl
>> es/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-exampl
>> es/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-exampl
>> es/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-exampl
>> es/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-exampl
>> es/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-exampl
>> es/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-exampl
>> es/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-exampl
>> es/src/main/java/org/apache/flink/storm/wordcount/WordCountTopology.java:[73,76]
>> incompatible types: org.apache.flink.storm.wordcou
>> nt.operators.WordCountFileSpout cannot be converted to
>> backtype.storm.topology.IRichSpout
>> [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-exampl
>> es/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-exampl
>> es/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-exampl
>> es/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-exampl
>> es/src/main/java/org/apache/flink/storm/wordcount/BoltToke
>> nizerWordCountPojo.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-exampl
>> es/src/main/java/org/apache/flink/storm/wordcount/WordCoun
>> tRemoteBySubmitter.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-exampl
>> es/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-exampl
>> es/src/main/java/org/apache/flink/storm/wordcount/BoltToke
>> nizerWordCountWithNames.java:[76,49] no suitable constructor found for
>> BoltWrapper(org.apache.flink.storm.wordcount.operators.BoltT
>> okenizerByName,org.apache.storm.tuple.Fields)
>> [ERROR] constructor org.apache.flink.storm.wrapper
>> s.BoltWrapper.BoltWrapper(backtype.storm.topology.
>> IRichBolt,backtype.storm.tuple.Fields) is not applicable
>> [ERROR] (argument mismatch; org.apache.flink.storm.wordcou
>> nt.operators.BoltTokenizerByName cannot be converted to
>> backtype.storm.topology.IRichBolt)
>> [ERROR] constructor org.apache.flink.storm.wrapper
>> s.BoltWrapper.BoltWrapper(backtype.storm.topology.IRichBolt,java.lang.String[])
>> is not applicable
>> [ERROR] (argument mismatch; org.apache.flink.storm.wordcou
>> nt.operators.BoltTokenizerByName cannot be converted to
>> backtype.storm.topology.IRichBolt)
>> [ERROR] constructor org.apache.flink.storm.wrapper
>> s.BoltWrapper.BoltWrapper(backtype.storm.topology.
>> IRichBolt,java.util.Collection<java.lang.String>) is not applicable
>> [ERROR] (argument mismatch; org.apache.flink.storm.wordcou
>> nt.operators.BoltTokenizerByName cannot be converted to
>> backtype.storm.topology.IRichBolt)
>> [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-exampl
>> es/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.wrapper
>> s.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.wrapper
>> s.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.wrapper
>> s.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-exampl
>> es/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.wrapper
>> s.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.wrapper
>> s.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.wrapper
>> s.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-exampl
>> es/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-exampl
>> es/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.wrapper
>> s.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.wrapper
>> s.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-exampl
>> es/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-exampl
>> es/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.wrapper
>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.
>> IRichSpout,java.lang.String[],java.lang.Integer) is not applicable
>> [ERROR] (argument mismatch; org.apache.flink.storm.wordcou
>> nt.operators.WordCountFileSpout cannot be converted to
>> backtype.storm.topology.IRichSpout)
>> [ERROR] constructor org.apache.flink.storm.wrapper
>> s.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.wordcou
>> nt.operators.WordCountFileSpout cannot be converted to
>> backtype.storm.topology.IRichSpout)
>> [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-exampl
>> es/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.wrapper
>> s.SpoutWrapper.SpoutWrapper(backtype.storm.topology.
>> IRichSpout,java.lang.String[],java.lang.Integer) is not applicable
>> [ERROR] (argument mismatch; org.apache.flink.storm.wordcou
>> nt.operators.WordCountInMemorySpout cannot be converted to
>> backtype.storm.topology.IRichSpout)
>> [ERROR] constructor org.apache.flink.storm.wrapper
>> s.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.wordcou
>> nt.operators.WordCountInMemorySpout cannot be converted to
>> backtype.storm.topology.IRichSpout)
>> [ERROR] /Users/lior/src/flink/flink/flink-contrib/flink-storm-exampl
>> es/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/conflu
>> ence/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 <yu...@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
>>>>
>>>
>>>
>>
>
Re: Compiling Flink on macOS.
Posted by Ted Yu <yu...@gmail.com>.
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 <li...@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 <yu...@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
>>>
>>
>>
>
Re: Compiling Flink on macOS.
Posted by Lior Amar <li...@parallelmachines.com>.
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 <yu...@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
>>
>
>
Re: Compiling Flink on macOS.
Posted by Ted Yu <yu...@gmail.com>.
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 <li...@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
>