csv file as input to kafka-to-hdfs-sync app in Datatorrent

9 views
Skip to first unread message

akshay naidu

unread,
Dec 28, 2016, 9:43:24 AM12/28/16
to apex-dev
Hello, 
     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 
Screenshot from 2016-12-28 20:10:22.png
Reply all
Reply to author
Forward
0 new messages