I am newbie in Datatorrent,
I am trying to launch kafka-to-hdfs-sync App in Datatorrent. I have a .csv file in hdfs, i want to give this file as input to this app.
I maybe wrong but my 1st guess is to add path to .csv file in one of the dt.operator.kafkaInput....properties.. under "Specify custom properties" . But when I add path to csv file, which is '/user/dtadmin/data/xyz.csv' , the application launches successfully but when I open the application link given in the notification it shows the status as failed in application overview page.
I have attached a screenshot with the configs that i have saved.
kindly assist me. Its urgent.
Thank you