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 <yuzhih...@gmail.com> wrote: > commit d6aed38b3a15946d383d762030b5f5c1418388de > Author: wenlong.lwl <wenlong....@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 <yuzhih...@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.a...@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 <yuzhih...@gmail.com> wrote: >>>> >>>>> Can you show the error(s) you got ? >>>>> >>>>> What is the Java version you're using ? >>>>> >>>>> Thanks >>>>> >>>>> On Wed, Feb 22, 2017 at 10:24 AM, Lior Amar < >>>>> lior.a...@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 >>>>>> >>>>> >>>>> >>>> >>> >> >
