hi, i tried to create a simple pig job flow, i have files on remote HDFS and tried to run a simple pig script to filter out data by column, then dump the result to local file

so i have 3 components: tHDFSGet_1 connect to tPigCode_1 by row1(Main) and tiPigCode_1 to tFileOutputDelimited_1 by row2(Pig), however it showed on the first connection as:
if this component has ouptput, there must be an input link to propagate the data

then i removed the first connection, and tried to create 'onJobOk' connection, but it refused to connect those two component. i have no idea what's go wrong, please help. thanks,