Uploaded image for project: 'Apache Storm'
  1. Apache Storm
  2. STORM-2511

Submitting a topology with name containing unicode getting failed.

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Critical
    • Resolution: Fixed
    • 2.0.0, 1.x
    • 2.0.0, 1.0.4, 1.1.1, 1.2.0
    • storm-core
    • None

    Description

      Below error occurs when a topology name contains unicode characters.

      $ storm jar WordCountTopology-1.0-SNAPSHOT.jar examples.WordCountTopology "wordcount-中文topology"

      2624 [main] INFO o.a.s.StormSubmitter - Submitting topology wordcount-中文topology in distributed mode with conf

      Unknown macro: {"storm.zookeeper.topology.auth.scheme"}

      Exception in thread "main" java.lang.RuntimeException: AuthorizationException(msg:wordcount-中文topology-4-1483689231-stormconf.ser does not appear to be a valid blob key)
      at org.apache.storm.StormSubmitter.submitTopologyAs(StormSubmitter.java:255)
      at org.apache.storm.StormSubmitter.submitTopology(StormSubmitter.java:310)
      at org.apache.storm.StormSubmitter.submitTopologyWithProgressBar(StormSubmitter.java:346)
      at org.apache.storm.StormSubmitter.submitTopologyWithProgressBar(StormSubmitter.java:327)
      at com.microsoft.example.KafkaReaderTop.main(KafkaReaderTop.java:39)
      Caused by: AuthorizationException(msg:wordcount-中文topology-4-1483689231-stormconf.ser does not appear to be a valid blob key)
      at org.apache.storm.generated.Nimbus$submitTopology_result$submitTopology_resultStandardScheme.read(Nimbus.java:7628)
      at org.apache.storm.generated.Nimbus$submitTopology_result$submitTopology_resultStandardScheme.read(Nimbus.java:7596)
      at org.apache.storm.generated.Nimbus$submitTopology_result.read(Nimbus.java:7530)
      at org.apache.storm.thrift.TServiceClient.receiveBase(TServiceClient.java:86)
      at org.apache.storm.generated.Nimbus$Client.recv_submitTopology(Nimbus.java:294)
      at org.apache.storm.generated.Nimbus$Client.submitTopology(Nimbus.java:278)
      at org.apache.storm.StormSubmitter.submitTopologyAs(StormSubmitter.java:243)
      ... 4 more

      Attachments

        Issue Links

          Activity

            People

              satish.duggana Satish Duggana
              satish.duggana Satish Duggana
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved:

                Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 0.5h
                  0.5h