flink-user mailing list archives

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