Here is the .dot file.
One thing that looks strange: line 2, there are 3 levels of [ in the
definition of SequenceFile. I've noticed in a few of the error dumps
that sometimes the field names are enclosed in [ ] and sometimes not.
Is that showing some unexpected level of nesting?
digraph G {
1 [label = "Every('reformat')[RowAggregator[decl:['Mailing Id'],
['Report Id'], ['Campaign Id'], ['Recipient Id'], ['Recipient Type'],
['Email'], ['DOMAIN'], ['Suppression Reason'], ['SENT'],
['DAYS_IN_LIST'], ['DAYS_IN_LIST_BUCKET'], ['OPENS_TOTAL'],
['OPENS_HTML'], ['OPENS_AOL'], ['OPENS_TEXT'], ['OPENS_WEB'],
['OPENS_FIRST'], ['OPENS_LAST'], ['CLICK_TOTAL_ANY'],
['CLICK_TOTAL_HTML'], ['CLICK_TOTAL_AOL'], ['CLICK_TOTAL_TEXT'],
['CLICK_TOTAL_WEB'], ['CLICK_ANY_FIRST'], ['CLICK_ANY_LAST'],
['FTF_TOTAL'], ['FTF_FIRST'], ['FTF_LAST'], ['CONVERSIONS_TOTAL'],
['CONVERSIONS_AMOUNT'], ['CONVERSION_FIRST'], ['CONVERSION_LAST'],
['HARD_BOUNCE'], ['SOFT_BOUNCE'], ['BOUNCE_DATE'],
['OPTED_OUT_FROM_MAILING'], ['OPTED_OUT_FROM_MAILING_DATE'],
['OPTED_OUT_VIA_ABUSE'], ['OPTED_OUT_VIA_ABUSE_DATE'],
['REPLY_MAIL_BLOCK'], ['REPLY_MAIL_BLOCK_DATE'],
['REPLY_MAIL_RESTRICTION'], ['REPLY_MAIL_RESTRICTION_DATE'],
['REPLY_COUNT'], ['REPLY_FIRST'], ['REPLY_LAST'], ['Opted Out'],
['frequency'], ['Opted Out Date'], ['Opt In Date'], ['Opt Out
Details'], ['google_total'], ['google_html'], ['google_aol'],
['google_text'], ['google_web'], ['google_first'], ['google_last'],
['other_total'], ['other_html'], ['other_aol'], ['other_text'],
['other_web'], ['other_first'], ['other_last']]]"];
2 [label = "Lfs['SequenceFile[[['Mailing Id'], ['Report Id'],
['Campaign Id'], ['Recipient Id'], ['Recipient Type'], ['Email'],
['DOMAIN'], ['Suppression Reason'], ['SENT'], ['DAYS_IN_LIST'],
['DAYS_IN_LIST_BUCKET'], ['OPENS_TOTAL'], ['OPENS_HTML'],
['OPENS_AOL'], ['OPENS_TEXT'], ['OPENS_WEB'], ['OPENS_FIRST'],
['OPENS_LAST'], ['CLICK_TOTAL_ANY'], ['CLICK_TOTAL_HTML'],
['CLICK_TOTAL_AOL'], ['CLICK_TOTAL_TEXT'], ['CLICK_TOTAL_WEB'],
['CLICK_ANY_FIRST'], ['CLICK_ANY_LAST'], ['FTF_TOTAL'], ['FTF_FIRST'],
['FTF_LAST'], ['CONVERSIONS_TOTAL'], ['CONVERSIONS_AMOUNT'],
['CONVERSION_FIRST'], ['CONVERSION_LAST'], ['HARD_BOUNCE'],
['SOFT_BOUNCE'], ['BOUNCE_DATE'], ['OPTED_OUT_FROM_MAILING'],
['OPTED_OUT_FROM_MAILING_DATE'], ['OPTED_OUT_VIA_ABUSE'],
['OPTED_OUT_VIA_ABUSE_DATE'], ['REPLY_MAIL_BLOCK'],
['REPLY_MAIL_BLOCK_DATE'], ['REPLY_MAIL_RESTRICTION'],
['REPLY_MAIL_RESTRICTION_DATE'], ['REPLY_COUNT'], ['REPLY_FIRST'],
['REPLY_LAST'], ['Opted Out'], ['frequency'], ['Opted Out Date'],
['Opt In Date'], ['Opt Out Details'], ['google_total'],
['google_html'], ['google_aol'], ['google_text'], ['google_web'],
['google_first'], ['google_last'], ['other_total'], ['other_html'],
['other_aol'], ['other_text'], ['other_web'], ['other_first'],
['other_last']]]']['c:/temp/clouds/test_data/local/output/
7_flat']']"];
3 [label = "GroupBy('reformat')[by:['Recipient Id']]"];
4 [label = "Each('reformat')[MetricsParser[decl:'Recipient Id',
'Recipient Type', 'Mailing Id', 'Report Id', 'Campaign Id', 'Email',
'Event Type', 'Event Timestamp', 'Body Type', 'Content Id', 'Click
Name', 'URL', 'Conversion Action', 'Conversion Detail', 'Conversion
Amount', 'Suppression Reason', 'Opted Out', 'frequency', 'Opted Out
Date', 'Opt In Date', 'Opt Out Details']]"];
5 [label = "MultiTap[[Lfs['TextLine[['offset', 'line']->[ALL]]']['c:/
temp/clouds/test_data/local/source/7_sent']'], Lfs['TextLine
[['offset', 'line']->[ALL]]']['c:/temp/clouds/test_data/local/source/
7_metrics']']]]"];
6 [label = "[head]"];
7 [label = "[tail]"];
1 -> 2 [label = "['Recipient Id', 1:65]\n['Recipient Id', 'Recipient
Type', 'Mailing Id', 'Report Id', 'Campaign Id', 'Email', 'Event
Type', 'Event Timestamp', 'Body Type', 'Content Id', 'Click Name',
'URL', 'Conversion Action', 'Conversion Detail', 'Conversion Amount',
'Suppression Reason', 'Opted Out', 'frequency', 'Opted Out Date', 'Opt
In Date', 'Opt Out Details']"];
5 -> 4 [label = "['offset', 'line']\n['offset', 'line']"];
4 -> 3 [label = "['Recipient Id', 'Recipient Type', 'Mailing Id',
'Report Id', 'Campaign Id', 'Email', 'Event Type', 'Event Timestamp',
'Body Type', 'Content Id', 'Click Name', 'URL', 'Conversion Action',
'Conversion Detail', 'Conversion Amount', 'Suppression Reason', 'Opted
Out', 'frequency', 'Opted Out Date', 'Opt In Date', 'Opt Out Details']
\n['Recipient Id', 'Recipient Type', 'Mailing Id', 'Report Id',
'Campaign Id', 'Email', 'Event Type', 'Event Timestamp', 'Body Type',
'Content Id', 'Click Name', 'URL', 'Conversion Action', 'Conversion
Detail', 'Conversion Amount', 'Suppression Reason', 'Opted Out',
'frequency', 'Opted Out Date', 'Opt In Date', 'Opt Out Details']"];
3 -> 1 [label = "reformat['Recipient Id']\n['Recipient Id',
'Recipient Type', 'Mailing Id', 'Report Id', 'Campaign Id', 'Email',
'Event Type', 'Event Timestamp', 'Body Type', 'Content Id', 'Click
Name', 'URL', 'Conversion Action', 'Conversion Detail', 'Conversion
Amount', 'Suppression Reason', 'Opted Out', 'frequency', 'Opted Out
Date', 'Opt In Date', 'Opt Out Details']"];
6 -> 5 [label = ""];
2 -> 7 [label = ""];
}