You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by Ramiro Rivera <ra...@gmail.com> on 2018/06/21 02:32:10 UTC
Weird console output on Windows
Hello all.
I'm experiencing an odd issue when running pretty much anything from
windows powershell.
As you can see in the attached image, the output for running a topology
with flux is not being properly displayed (please ignore both the storm.env
error and the actual error messages, those are because of my code/settings
I believe)
Text output (in case there is some issue with images)
ramar@BLACKTITAN C:\Development\streaming-analysis [master +9 ~0 -0 | +2
>> ~10 -0 !]
>
> > storm jar .\target\streaming-analysis-1.0-SNAPSHOT.jar
>> org.apache.storm.flux.Flux --local .\local-flux.yaml
>
> . : File C:\Development\apache-storm-1.2.2\conf\storm-env.ps1 cannot be
>> loaded. The file C:\Development\apache-storm-1.2.2\conf\storm-env.ps1 is
>> not digitally signed. You cannot run this script
>
> on the current system. For more information about running scripts and
>> setting execution policy, see about_Execution_Policies at https:/
>> go.microsoft.com/fwlink/?LinkID=135170.
>
> At C:\Development\apache-storm-1.2.2\bin\storm.ps1:63 char:5
>
> + . $StormEnvPath;
>
> + ~~~~~~~~~~~~~
>
> + CategoryInfo : SecurityError: (:) [], PSSecurityException
>
> + FullyQualifiedErrorId : UnauthorizedAccess
>
> Running: C:\Java\jdk1.8.0_144\bin\java.exe -client -Ddaemon.name=
>> -Dstorm.options= -Dstorm.home=C:\Development\apache-storm-1.2.2
>> -Dstorm.log.dir=C:\Development\apache-storm-1.2.2\logs
>> -Djava.library.path=/usr/local/lib:/opt/local/lib:/usr/lib
>> -Dstorm.conf.file= -cp
>> C:\Development\apache-storm-1.2.2\*;C:\Development\apache-storm-1.2.2/lib\*;C:\Development\apache-storm-1.2.2/extlib\*;.\target\streaming-analysis-1.0-SNAPSHOT.jar;C:\Development\apache-storm-1.2.2\conf;C:\Development\apache-storm-1.2.2\bin
>> -Dstorm.jar=.\target\streaming-analysis-1.0-SNAPSHOT.jar
>> -Dstorm.dependency.jars= -Dstorm.dependency.artifacts={}
>> org.apache.storm.flux.Flux --local .\local-flux.yaml
>
> b'??????????? ??? ?????? ???\r\n??????????? ???
>> ???????????\r\n?????? ??? ??? ??? ??????\r\n?????? ??? ???
>> ??? ??????\r\n??? ????????????????????? ???\r\n??? ????????
>> ??????? ??? ???\r\n+- Apache Storm -+\r\n+- data FLow User
>> eXperience -+\r\nVersion: 1.2.2\r\nParsing file:
>> C:\\Development\\streaming-analysis\\.\\local-flux.yaml\r\n569 [main]
>> INFO o.a.s.f.p.FluxParser - loading YAML from input stream...\r\n576
>> [main] INFO o.a.s.f.p.FluxParser - Not performing property
>> substitution.\r\n576 [main] INFO o.a.s.f.p.FluxParser - Not performing
>> environment variable substitution.\r\nException in thread "main" Can\'t
>> construct a java object for tag:yaml.org,2002:org.apache.storm.flux.model.TopologyDef;
>> exception=Cannot create property=streams for
>> JavaBean=org.apache.storm.flux.model.TopologyDef@564718df; Cannot create
>> property=grouping for
>> JavaBean=org.apache.storm.flux.model.StreamDef@2b4a2ec7; Cannot create
>> property=type for JavaBean=org.apache.storm.flux.model.GroupingDef@51931956;
>> Unable to find enum value \'SUFFLE\' for enum class:
>> org.apache.storm.flux.model.GroupingDef$Type\n in \'string\', line 1,
>> column 1:\n name: "yaml-topology"\n ^\n\r\n\tat
>> org.yaml.snakeyaml.constructor.Constructor$ConstructYamlObject.construct(Constructor.java:333)\r\n\tat
>> org.yaml.snakeyaml.constructor.BaseConstructor.constructObject(BaseConstructor.java:182)\r\n\tat
>> org.yaml.snakeyaml.constructor.BaseConstructor.constructDocument(BaseConstructor.java:141)\r\n\tat
>> org.yaml.snakeyaml.constructor.BaseConstructor.getSingleData(BaseConstructor.java:127)\r\n\tat
>> org.yaml.snakeyaml.Yaml.loadFromReader(Yaml.java:481)\r\n\tat
>> org.yaml.snakeyaml.Yaml.load(Yaml.java:400)\r\n\tat
>> org.apache.storm.flux.parser.FluxParser.loadYaml(FluxParser.java:172)\r\n\tat
>> org.apache.storm.flux.parser.FluxParser.parseInputStream(FluxParser.java:104)\r\n\tat
>> org.apache.storm.flux.parser.FluxParser.parseFile(FluxParser.java:60)\r\n\tat
>> org.apache.storm.flux.Flux.runCli(Flux.java:151)\r\n\tat
>> org.apache.storm.flux.Flux.main(Flux.java:103)\r\nCaused by:
>> org.yaml.snakeyaml.error.YAMLException: Cannot create property=streams for
>> JavaBean=org.apache.storm.flux.model.TopologyDef@564718df; Cannot create
>> property=grouping for
>> JavaBean=org.apache.storm.flux.model.StreamDef@2b4a2ec7; Cannot create
>> property=type for JavaBean=org.apache.storm.flux.model.GroupingDef@51931956;
>> Unable to find enum value \'SUFFLE\' for enum class:
>> org.apache.storm.flux.model.GroupingDef$Type\r\n\tat
>> org.yaml.snakeyaml.constructor.Constructor$ConstructMapping.constructJavaBean2ndStep(Constructor.java:299)\r\n\tat
>> org.yaml.snakeyaml.constructor.Constructor$ConstructMapping.construct(Constructor.java:189)\r\n\tat
>> org.yaml.snakeyaml.constructor.Constructor$ConstructYamlObject.construct(Constructor.java:331)\r\n\t...
>> 10 more\r\nCaused by: org.yaml.snakeyaml.error.YAMLException: Cannot create
>> property=grouping for
>> JavaBean=org.apache.storm.flux.model.StreamDef@2b4a2ec7; Cannot create
>> property=type for JavaBean=org.apache.storm.flux.model.GroupingDef@51931956;
>> Unable to find enum value \'SUFFLE\' for enum class:
>> org.apache.storm.flux.model.GroupingDef$Type\r\n\tat
>> org.yaml.snakeyaml.constructor.Constructor$ConstructMapping.constructJavaBean2ndStep(Constructor.java:299)\r\n\tat
>> org.yaml.snakeyaml.constructor.Constructor$ConstructMapping.construct(Constructor.java:189)\r\n\tat
>> org.yaml.snakeyaml.constructor.BaseConstructor.constructObject(BaseConstructor.java:182)\r\n\tat
>> org.yaml.snakeyaml.constructor.BaseConstructor.constructSequenceStep2(BaseConstructor.java:276)\r\n\tat
>> org.yaml.snakeyaml.constructor.BaseConstructor.constructSequence(BaseConstructor.java:247)\r\n\tat
>> org.yaml.snakeyaml.constructor.Constructor$ConstructSequence.construct(Constructor.java:509)\r\n\tat
>> org.yaml.snakeyaml.constructor.BaseConstructor.constructObject(BaseConstructor.java:182)\r\n\tat
>> org.yaml.snakeyaml.constructor.Constructor$ConstructMapping.constructJavaBean2ndStep(Constructor.java:296)\r\n\t...
>> 12 more\r\nCaused by: org.yaml.snakeyaml.error.YAMLException: Cannot create
>> property=type for JavaBean=org.apache.storm.flux.model.GroupingDef@51931956;
>> Unable to find enum value \'SUFFLE\' for enum class:
>> org.apache.storm.flux.model.GroupingDef$Type\r\n\tat
>> org.yaml.snakeyaml.constructor.Constructor$ConstructMapping.constructJavaBean2ndStep(Constructor.java:299)\r\n\tat
>> org.yaml.snakeyaml.constructor.Constructor$ConstructMapping.construct(Constructor.java:189)\r\n\tat
>> org.yaml.snakeyaml.constructor.BaseConstructor.constructObject(BaseConstructor.java:182)\r\n\tat
>> org.yaml.snakeyaml.constructor.Constructor$ConstructMapping.constructJavaBean2ndStep(Constructor.java:296)\r\n\t...
>> 19 more\r\nCaused by: org.yaml.snakeyaml.error.YAMLException: Unable to
>> find enum value \'SUFFLE\' for enum class:
>> org.apache.storm.flux.model.GroupingDef$Type\r\n\tat
>> org.yaml.snakeyaml.constructor.Constructor$ConstructScalar.constructStandardJavaInstance(Constructor.java:477)\r\n\tat
>> org.yaml.snakeyaml.constructor.Constructor$ConstructScalar.construct(Constructor.java:365)\r\n\tat
>> org.yaml.snakeyaml.constructor.BaseConstructor.constructObject(BaseConstructor.java:182)\r\n\tat
>> org.yaml.snakeyaml.constructor.Constructor$ConstructMapping.constructJavaBean2ndStep(Constructor.java:296)\r\n\t...
>> 22 more\r\n'
>
>
>
I've also noticed that there are \n\r where there should be new lines, \t
where tabs should be (I'm guessing) and ?? characters where the characters
should spell FLUX. I think the expected output is something like this:
███████╗██╗ ██╗ ██╗██╗ ██╗
██╔════╝██║ ██║ ██║╚██╗██╔╝
█████╗ ██║ ██║ ██║ ╚███╔╝
██╔══╝ ██║ ██║ ██║ ██╔██╗
██║ ███████╗╚██████╔╝██╔╝ ██╗
╚═╝ ╚══════╝ ╚═════╝ ╚═╝ ╚═╝
+- Apache Storm -+
+- data FLow User eXperience -+
Version: 0.3.0
Parsing file: /Users/hsimpson/Projects/donut_domination/storm/shell_test.yaml
---------- TOPOLOGY DETAILS ----------
Name: shell-topology
Just in case, when running "storm jar ... " I also get a similarly
malformatted output, as follows:
Is there anything I could do to fix this, or is any one else experiencing a
similar issue?
I'm running windows 10 and powershell 5.1.x, just in case.
Thanks in advanced for your help.
Best regards,
Ramiro