DSXchange

Indeed, if that's ALL you want to do, lose the Aggregator stage altogether, go with just the Remove Duplicates stage. It has similar partitioning and sorting requirements to those of the Aggregator stage.

Is there an output link (unconditional trigger) from your EndLoop activity to "the rest of the job sequence"?

Of course you can do it. Create a DataStage job that reads the flat file and writes the rows into a Data Set. A before-job subroutine could even create the file!

Intermediate files (as I mentioned in my initial response to this thread) are not permitted in parallel jobs. They are "blocking operations" and interfere with pipeline parallelism. If you need two streams, insert a Copy stage.

DS functions can not be used in the parallel job until they are available from the Transformer (expression editor). For this to happen, you have to create the parallel routines. A parallel routine in the Repository is merely an interlude to a C++ function that you yourself have written, compiled and...

Until you create the reject link and report some values for the date column from it, you will be getting no more help from me on this thread.

If that doesn't work, try \n

Observation: @INROWNUM < 1 will "work" - inasmuch as the job will compile and run without error, evaluating its stage variable(s) - but will not generate any rows.

The "other way" is probably to have a before-stage or after-stage subroutine.

You have misunderstood my intent. If you don't have NLS enabled, that's one less possible cause for the problem. Leave it disabled until you can solve the handling of 253 without it.

Can you please list ALL of the values from the Format tab of the Sequential File stage that writes this file?

The individual part files are Type 30. The Distributed file itself, although it is only a logical entity, is Type 27.

If that's the case, apply an Iconv() function in the stage variable derivation.

Welcome aboard. :D Setting the User Status variable is, as you observe, a matter of calling the DSSetUserStatus subroutine. However, if you need to call it via a transform function you will need an interlude such as: FUNCTION SetUserStatus(Arg1) Ans = Arg1 ; * pass input argument unchanged C...

Check in again in another 30 days, and tell us whether the routine still "works fine".