-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(
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
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
-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
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
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
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
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
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).