Re: Error due to Hadoop version mismatch

2015-12-22 Thread Kashmar, Ali
Hi Robert, I found the version in the job manager log file: 17:33:49,636 INFO org.apache.flink.runtime.jobmanager.JobManager - Hadoop version: 2.6.0 But the Hadoop installation I have is saying this: ubuntu@ubuntu-171:~/Documents/hadoop-2.6.0$ bin/hadoop version Hadoop 2.6.0 Subversion

Re: Error due to Hadoop version mismatch

2015-12-22 Thread Robert Metzger
Hi Ali, the TaskManagers and the JobManager is logging the Hadoop version on startup. On Tue, Dec 22, 2015 at 4:10 PM, Kashmar, Ali wrote: > Hello, > > I’m trying to use HDFS as store for Flink checkpoints so I downloaded the > Hadoop 2.6.0/Scala 2.10 version of Flink and installed it. I also >

Error due to Hadoop version mismatch

2015-12-22 Thread Kashmar, Ali
Hello, I’m trying to use HDFS as store for Flink checkpoints so I downloaded the Hadoop 2.6.0/Scala 2.10 version of Flink and installed it. I also downloaded Hadoop 2.6.0 separately from the Hadoop website and set up HDFS on a separate machine. When I start Flink I get the following error: 17: