Uploaded image for project: 'Talend Component Kit'
  1. Talend Component Kit
  2. TCOMP-1736

JobImpl retrieves more than streaming.maxRecords parameter

Apply templateInsert Lucidchart DiagramXMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Fixed
    • Icon: Minor Minor
    • 1.1.23
    • None
    • None
    • All
    • Small

      This condition:

      https://github.com/Talend/component-runtime/blob/master/component-runtime-manager/src/main/java/org/talend/sdk/component/runtime/manager/chain/internal/JobImpl.java#L606

      makes component wait for maxRecord + 1 record count.
      It should be currentRecords >= maxRecords

      May be the problem for Streaming components IT tests or if we specify maxRecords in a job.

            emmanuel_g emmanuel gallois
            mbasiuk Maksym Basiuk (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

              Created:
              Updated:
              Resolved: