Reading Data Using TextFileStream

2015-01-06 Thread Jeniba Johnson
-hadoop1.0.4.jar,lib/mysql.jar --master local[*] --deploy-mode client --class xyz.Test1 bin/filestream3.jar Regards, Jeniba Johnson The contents of this e-mail and any attachment(s) may contain confidential or privileged information for the intended recipient(

Data Loss - Spark streaming

2014-12-16 Thread Jeniba Johnson
streaming ? Will that data be stored somewhere or else the data will be lost ? Or else what is the solution to capture each and every data without any loss in Spark streaming. Awaiting for your kind reply. Regards, Jeniba Johnson The contents of this e-mail and any

Spark-Submit issues

2014-11-11 Thread Jeniba Johnson
g for your kind reply Regards, Jeniba Johnson The contents of this e-mail and any attachment(s) may contain confidential or privileged information for the intended recipient(s). Unintended recipients are prohibited from taking action on the basis of informatio

RE: Bind exception while running FlumeEventCount

2014-11-11 Thread Jeniba Johnson
-ng agent -n agent1 -c conf -f conf/test12.conf -Dflume.root.logger=DEBUG,console Even after changing the port several times, still Iam facing with the same issues, Kindly look into my conf file and just let me know the steps. Regards, Jeniba Johnson From: Hari Shreedharan [mailto:hshreedha

RE: Bind exception while running FlumeEventCount

2014-11-10 Thread Jeniba Johnson
or else Is there any other way, then just let me know. Awaiting for your kind reply. Regards, Jeniba Johnson From: Hari Shreedharan [mailto:hshreedha...@cloudera.com] Sent: Tuesday, November 11, 2014 12:41 PM To: Jeniba Johnson Cc: dev@spark.apache.org Subject: RE: Bind exception while running

RE: Bind exception while running FlumeEventCount

2014-11-10 Thread Jeniba Johnson
exactly.. Iam attaching the screenshot ,so that you can help me with it The screenshot specify the ports listening after the program is executed Regards, Jeniba Johnson -Original Message- From: Hari Shreedharan [mailto:hshreedha...@cloudera.com] Sent: Tuesday, November 11, 2014 11:04 AM

RE: Bind exception while running FlumeEventCount

2014-11-10 Thread Jeniba Johnson
emains the same. Regards, Jeniba Johnson From: Hari Shreedharan [mailto:hshreedha...@cloudera.com] Sent: Tuesday, November 11, 2014 4:41 AM To: Jeniba Johnson Cc: dev@spark.apache.org Subject: Re: Bind exception while running FlumeEventCount Looks like that port is not available because another ap

Bind exception while running FlumeEventCount

2014-11-10 Thread Jeniba Johnson
nPool.java:1979) at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) Regards, Jeniba Johnson The contents of this e-mail and any attachment(s) may contain confidential or privileged information for the intended r

Bind exception while running FlumeEventCount

2014-11-07 Thread Jeniba Johnson
nPool.java:1979) at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) Regards, Jeniba Johnson The contents of this e-mail and any attachment(s) may contain confidential or privileged information for the intended recipient(s).