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/ > 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 <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 >>>> >>> >>> >> >
