Kafka, mail # user - RE: Leader not local for partition error? - 2013-07-30, 16:19
 Search Hadoop and all its subprojects:

Switch to Plain View
Jun Rao 2013-07-22, 04:39
Jun Rao 2013-07-30, 04:32
Copy link to this message
RE: Leader not local for partition error?
Nope, that's on a pretty standard GNU/Linux Debian system (jessie/sid) running a 3.9.8-1 kernel. But you were onto something. Removing the trailing slash is my log.dir config value made it work.

I'm not sure why this would have an impact since the log directories seem to be correctly parsed as File objects in LogManager.scala:

  val logDirs: Array[File] = config.logDirs.map(new File(_)).toArray

And in both cases the server logs reports that the log for 'test-0' was correctly loaded, which means that log directory is also correctly inserted into the logs Pool[TopicAndPartition, Log].

That's about as far as my Scala knowledge goes though ;-) Let me know if you're able to reproduce the problem when you have a trailing slash as well.

Maxime Petazzoni
Sr. Platform Engineer
m 408.310.0595

Sent: Monday, July 29, 2013 9:32 PM
Subject: Re: Leader not local for partition error?

Are you on Windows? We have seen issues like that before on Windows. You
may have to use "/" when configuring  "log.dirs".


On Mon, Jul 29, 2013 at 4:50 PM, Maxime Petazzoni <[EMAIL PROTECTED]
Jun Rao 2013-07-31, 04:01
Maxime Petazzoni 2013-07-15, 20:36
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB