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 18:53:00 GMT
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/
> 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 <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