Uploaded image for project: 'Spring XD'
  1. Spring XD
  2. XD-2806

Module count not respected when label is used

This issue belongs to an archived project. You can view it, but you can't modify it. Learn more

    XMLWordPrintable

Details

    • Bug
    • Status: Done
    • Critical
    • Resolution: Complete
    • 1.1 GA
    • 1.2 M1
    • Configuration
    • None
    • 3
    • 9223372036854775807
    • Sprint 45

    Description

      xd:> stream create test --definition "http | t1:transform --expression=payload | log"
      xd:>stream deploy test --properties module.t1.count=2
      Deployed stream 'test'
      xd:>runtime modules
        Module Id            Container Id                          Options                                                                                                                                                                                            Deployment Properties                                                                       Unit status
        -------------------  ------------------------------------  -------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------  ------------------------------------------------------------------------------------------  -----------
        test.processor.t1.1  393d3af0-68e8-49b2-8601-da063cfbf98a  {valid=true, expression=payload}                                                                                                                                                                   {consumer.sequence=1, producer.next.module.count=1, count=1, consumer.count=1, sequence=1}  deployed
        test.sink.log.1      f6bb3189-9c0e-44e8-962b-025e2288ffe3  {name=test, expression=payload, level=INFO}                                                                                                                                                        {consumer.sequence=1, count=1, consumer.count=1, sequence=1}                                deployed
        test.source.http.1   f6bb3189-9c0e-44e8-962b-025e2288ffe3  {sslPropertiesLocation=classpath:httpSSL.properties, maxContentLength=1048576, port=9000, messageConverterClass=org.springframework.integration.x.http.NettyInboundMessageConverter, https=false}  {producer.next.module.count=1, count=1, sequence=1}                                         deployed
      

      *************************************
      Works fine without the label:
      *************************************

      xd:>stream destroy test
      Destroyed stream 'test'
      xd:>stream create test --definition "http | transform --expression=payload | log"
      Created new stream 'test'
      xd:>stream deploy test --properties module.transform.count=2
      Deployed stream 'test'
      xd:>runtime modules
        Module Id                   Container Id                          Options                                                                                                                                                                                            Deployment Properties                                                                       Unit status
        --------------------------  ------------------------------------  -------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------  ------------------------------------------------------------------------------------------  -----------
        test.processor.transform.1  f6bb3189-9c0e-44e8-962b-025e2288ffe3  {valid=true, expression=payload}                                                                                                                                                                   {consumer.sequence=1, producer.next.module.count=1, count=2, consumer.count=2, sequence=1}  deployed
        test.processor.transform.2  393d3af0-68e8-49b2-8601-da063cfbf98a  {valid=true, expression=payload}                                                                                                                                                                   {consumer.sequence=2, producer.next.module.count=1, count=2, consumer.count=2, sequence=2}  deployed
        test.sink.log.1             393d3af0-68e8-49b2-8601-da063cfbf98a  {name=test, expression=payload, level=INFO}                                                                                                                                                        {consumer.sequence=1, count=1, consumer.count=1, sequence=1}                                deployed
        test.source.http.1          f6bb3189-9c0e-44e8-962b-025e2288ffe3  {sslPropertiesLocation=classpath:httpSSL.properties, maxContentLength=1048576, port=9000, messageConverterClass=org.springframework.integration.x.http.NettyInboundMessageConverter, https=false}  {producer.next.module.count=2, count=1, sequence=1}                                         deployed
      

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              dturanski David Turanski
              Archiver:
              tmarshall Trevor Marshall

              Dates

                Created:
                Updated:
                Resolved:
                Archived: