You must have the reader incorrectly configured for your CSV schema.  ... View more

@Lallagreta   You should be able to define the filename, or change the filename to what you want.  That said the filename doesnt dictate the type,  so you can have parquet saved as .txt.   One recommendation I have is to use parquet command line tools during the testing of your use case.  This is the best way to validate that files are looking right, have the right schema, and right results.   https://pypi.org/project/parquet-tools/   I apologize i do not have any exact samples, but from my recall of a year ago,  you should be able to get simple commands to check schema of a file, and another command to show the data results.   You may have to copy your hdfs file to local file system to inspect them from command line.   If this answer resolves your issue or allows you to move forward, please choose to ACCEPT this solution and close this topic. If you have further dialogue on this topic please comment here or feel free to private message me. If you have new questions related to your Use Case please create separate topic and feel free to tag me in your post.   Thanks, Steven ... View more

@murali2425   The solution you are looking for is QueryRecord configured with a CSV Record Reader and Record Writer.   You also have UpdateRecord and ConvertRecord which can use the Readers/Writers.  This method is preferred over splitting the file and adds some nice functionality.  This method allows you to provide a schema for both the inbound csv (reader) and the downstream csv (writer).   Using QueryRecord you should be able to split the file, and set attribute of filename set to column1.  At the end of the flow you should be able to leverage that filename attribute to resave the new file.   You can find some specific examples and configuration screen shots here:   https://community.cloudera.com/t5/Community-Articles/Running-SQL-on-FlowFiles-using-QueryRecord-Processor-Apache/ta-p/246671   If this answer resolves your issue or allows you to move forward, please choose to ACCEPT this solution and close this topic. If you have further dialogue on this topic please comment here or feel free to private message me. If you have new questions related to your Use Case please create separate topic and feel free to tag me in your post.   Thanks, Steven ... View more

@pacman You would do better to create your own new Question with the same errors and any additional information you can provide.  Its unlikely the original poster will respond.   Just incase he does, and just incase this helps:   I think the solution you are looking for is to add a DistributedMapCacheServer.  The screenshot above is just the client.  The client needs a server running/enabled in order to be operational.       Another suggestion is to make sure that there is connectivity to the map cache port, between nifi,mysql, and the map cache port.   If this answer resolves your issue or allows you to move forward, please choose to ACCEPT this solution and close this topic. If you have further dialogue on this topic please comment here or feel free to private message me. If you have new questions related to your Use Case please create separate topic and feel free to tag me in your post.   Thanks, Steven ... View more