Ask Your Question

Revision history [back]

This is happening because the schema is changing between one record and the next. You need to set the roll attribute to tell the Hadoop FS destination to close the current file and open a new one. The Hive Metadata processor will do this for you.