flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Lior Amar <lior.a...@parallelmachines.com>
Subject Re: Compiling Flink on macOS.
Date Wed, 22 Feb 2017 19:21:05 GMT
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 <yuzhihong@gmail.com> wrote:

> commit d6aed38b3a15946d383d762030b5f5c1418388de
> Author: wenlong.lwl <wenlong.lwl@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 <yuzhihong@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 <yuzhihong@gmail.com> wrote:
>>>>
>>>>> Can you show the error(s) you got ?
>>>>>
>>>>> What is the Java version you're using ?
>>>>>
>>>>> Thanks
>>>>>
>>>>> On Wed, Feb 22, 2017 at 10:24 AM, Lior Amar <
>>>>> lior.amar@parallelmachines.com> wrote:
>>>>>
>>>>>> Hi all,
>>>>>>
>>>>>> My name is Lior and I an new to this community.
>>>>>> I am working on enhancing the python API of Flink (batch).
>>>>>>
>>>>>> I am having some issues compiling Flink on macOS with the latest
>>>>>> master, it seems that flink-storm-examples module is failing.
>>>>>> A quick question, how can I skip this module when I am compiling
on
>>>>>> Mac?
>>>>>> (it fine on our Linux cluster).
>>>>>>
>>>>>> Regards
>>>>>>
>>>>>> --lior
>>>>>>
>>>>>
>>>>>
>>>>
>>>
>>
>

Mime
View raw message