![]() | 1 | initial version |
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.