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.a...@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/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 <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 >>>>> >>>> >>>> >>> >> >
