Re: JobClientActorSubmissionTimeoutException

2016-02-01 Thread Ufuk Celebi
> On 01 Feb 2016, at 16:45, Hilmi Yildirim wrote: > > It seems that the exception is caused by a OutOfMemoryError. But this is only > visible in the logs Could you share the relevant parts? – Ufuk

Re: JobClientActorSubmissionTimeoutException

2016-02-01 Thread Hilmi Yildirim
It seems that the exception is caused by a OutOfMemoryError. But this is only visible in the logs Am 01.02.2016 um 15:17 schrieb Till Rohrmann: Yes if you provide a log4j.properties file in your class path which sets the log level to INFO and adds a console logger, you should see the output in

Re: JobClientActorSubmissionTimeoutException

2016-02-01 Thread Till Rohrmann
Yes if you provide a log4j.properties file in your class path which sets the log level to INFO and adds a console logger, you should see the output in the IntelliJ console. E.g. log4j.rootLogger=INFO, console log4j.appender.console=org.apache.log4j.ConsoleAppender log4j.appender.console.layout=or

Re: JobClientActorSubmissionTimeoutException

2016-02-01 Thread Hilmi Yildirim
Hi, I started the code with ExecutionEnvironment.createLocalEnvironment() Are there logs of the jobmanager in local mode? Best Regards, Hilmi Am 01.02.2016 um 14:50 schrieb Till Rohrmann: Hi Hilmi, could you check what happened on the JobManager side? Cheers, Till ​ On Mon, Feb 1, 2016 at

Re: JobClientActorSubmissionTimeoutException

2016-02-01 Thread Till Rohrmann
Hi Hilmi, could you check what happened on the JobManager side? Cheers, Till ​ On Mon, Feb 1, 2016 at 2:39 PM, Hilmi Yildirim wrote: > Hi, > > I get the following exception when I execute a code similar to the > ALSITSuite. I train a ALS model and when the following code is executed I > get t

JobClientActorSubmissionTimeoutException

2016-02-01 Thread Hilmi Yildirim
Hi, I get the following exception when I execute a code similar to the ALSITSuite. I train a ALS model and when the following code is executed I get the error: val predictions = als .predict(testData) .collect() Exception in thread "main" org.apache.flink.runtime.client.Job