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

Reject schema output for successful records

Apply templateInsert Lucidchart Diagram
    XMLWordPrintable

Details

    • Bug
    • Status: Rejected
    • Minor
    • Resolution: Fixed
    • None
    • None
    • None
    • All
    • Small

    Description

      Tried adding reject output for the component using following approach:

      public class OutputSink implements Serializable {
        ...
        @ElementListener
        public void onNext(@Input final JsonObject record,
                @Output("reject") final OutputEmitter<Reject> reject) throws SQLException {
            try {
                ...
                statement.execute();
            } catch (Exception e) {
                reject.emit(new Reject(e.getMessage(), record));
            }
        }
      

      When connecting Reject flow with tLogRow component, if all the records are successful we still receive the output with empty records:

      [statistics] connected
      |
      |
      |
      ...
      [statistics] disconnected
      

      And count of records above the Reject flow is also total count of records (including successful ones).

      Please clarify if this behavior is correct.

      Attachments

        Issue Links

          Activity

            People

              igonchar Ivan Gonchar
              ovarnavina Olha Varnavina (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: