[ https://issues.apache.org/jira/browse/KAFKA-5800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ahmed Mohsen updated KAFKA-5800: -------------------------------- Description: the server shutdown suddenly with this Exception {code:java} [2017-08-28 11:41:09,975] FATAL [Replica Manager on Broker 0]: Error writing to highwatermark file: (kafka.server.ReplicaManager) java.nio.file.FileAlreadyExistsException: D:\tmp\kafka-logs\replication-offset-checkpoint.tmp -> D:\tmp\kafka-logs\replication-offset-checkpoint at sun.nio.fs.WindowsException.translateToIOException(WindowsException.java:81) at sun.nio.fs.WindowsException.rethrowAsIOException(WindowsException.java:97) at sun.nio.fs.WindowsFileCopy.move(WindowsFileCopy.java:387) at sun.nio.fs.WindowsFileSystemProvider.move(WindowsFileSystemProvider.java:287) at java.nio.file.Files.move(Files.java:1395) at org.apache.kafka.common.utils.Utils.atomicMoveWithFallback(Utils.java:711) at kafka.server.OffsetCheckpoint.write(OffsetCheckpoint.scala:76) at kafka.server.ReplicaManager.$anonfun$checkpointHighWatermarks$5(ReplicaManager.scala:946) at kafka.server.ReplicaManager.$anonfun$checkpointHighWatermarks$5$adapted(ReplicaManager.scala:943) at kafka.server.ReplicaManager$$Lambda$862/1600997378.apply(Unknown Source) at scala.collection.TraversableLike$WithFilter.$anonfun$foreach$1(TraversableLike.scala:789) at scala.collection.TraversableLike$WithFilter$$Lambda$234/1781493632.apply(Unknown Source) at scala.collection.immutable.Map$Map1.foreach(Map.scala:120) at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:788) at kafka.server.ReplicaManager.checkpointHighWatermarks(ReplicaManager.scala:943) at kafka.server.ReplicaManager.$anonfun$startHighWaterMarksCheckPointThread$1(ReplicaManager.scala:163) at kafka.server.ReplicaManager$$Lambda$854/1298788908.apply$mcV$sp(Unknown Source) at kafka.utils.KafkaScheduler.$anonfun$schedule$2(KafkaScheduler.scala:110) at kafka.utils.KafkaScheduler$$Lambda$269/137460818.apply$mcV$sp(Unknown Source) at kafka.utils.CoreUtils$$anon$1.run(CoreUtils.scala:57) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745) Suppressed: java.nio.file.AccessDeniedException: D:\tmp\kafka-logs\replication-offset-checkpoint.tmp -> D:\tmp\kafka-logs\replication-offset-checkpoint at sun.nio.fs.WindowsException.translateToIOException(WindowsException.java:83) at sun.nio.fs.WindowsException.rethrowAsIOException(WindowsException.java:97) at sun.nio.fs.WindowsFileCopy.move(WindowsFileCopy.java:301) at sun.nio.fs.WindowsFileSystemProvider.move(WindowsFileSystemProvider.java:287) at java.nio.file.Files.move(Files.java:1395) at org.apache.kafka.common.utils.Utils.atomicMoveWithFallback(Utils.java:708) ... 21 more {code} was: the server shutdown suddenly with this Exception [2017-08-28 11:41:09,975] FATAL [Replica Manager on Broker 0]: Error writing to highwatermark file: (kafka.server.ReplicaManager) java.nio.file.FileAlreadyExistsException: D:\tmp\kafka-logs\replication-offset-checkpoint.tmp -> D:\tmp\kafka-logs\replication-offset-checkpoint at sun.nio.fs.WindowsException.translateToIOException(WindowsException.java:81) at sun.nio.fs.WindowsException.rethrowAsIOException(WindowsException.java:97) at sun.nio.fs.WindowsFileCopy.move(WindowsFileCopy.java:387) at sun.nio.fs.WindowsFileSystemProvider.move(WindowsFileSystemProvider.java:287) at java.nio.file.Files.move(Files.java:1395) at org.apache.kafka.common.utils.Utils.atomicMoveWithFallback(Utils.java:711) at kafka.server.OffsetCheckpoint.write(OffsetCheckpoint.scala:76) at kafka.server.ReplicaManager.$anonfun$checkpointHighWatermarks$5(ReplicaManager.scala:946) at kafka.server.ReplicaManager.$anonfun$checkpointHighWatermarks$5$adapted(ReplicaManager.scala:943) at kafka.server.ReplicaManager$$Lambda$862/1600997378.apply(Unknown Source) at scala.collection.TraversableLike$WithFilter.$anonfun$foreach$1(TraversableLike.scala:789) at scala.collection.TraversableLike$WithFilter$$Lambda$234/1781493632.apply(Unknown Source) at scala.collection.immutable.Map$Map1.foreach(Map.scala:120) at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:788) at kafka.server.ReplicaManager.checkpointHighWatermarks(ReplicaManager.scala:943) at kafka.server.ReplicaManager.$anonfun$startHighWaterMarksCheckPointThread$1(ReplicaManager.scala:163) at kafka.server.ReplicaManager$$Lambda$854/1298788908.apply$mcV$sp(Unknown Source) at kafka.utils.KafkaScheduler.$anonfun$schedule$2(KafkaScheduler.scala:110) at kafka.utils.KafkaScheduler$$Lambda$269/137460818.apply$mcV$sp(Unknown Source) at kafka.utils.CoreUtils$$anon$1.run(CoreUtils.scala:57) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745) Suppressed: java.nio.file.AccessDeniedException: D:\tmp\kafka-logs\replication-offset-checkpoint.tmp -> D:\tmp\kafka-logs\replication-offset-checkpoint at sun.nio.fs.WindowsException.translateToIOException(WindowsException.java:83) at sun.nio.fs.WindowsException.rethrowAsIOException(WindowsException.java:97) at sun.nio.fs.WindowsFileCopy.move(WindowsFileCopy.java:301) at sun.nio.fs.WindowsFileSystemProvider.move(WindowsFileSystemProvider.java:287) at java.nio.file.Files.move(Files.java:1395) at org.apache.kafka.common.utils.Utils.atomicMoveWithFallback(Utils.java:708) ... 21 more > FileAreadyExist when writing tmp Shutdown Server Suddenly > --------------------------------------------------------- > > Key: KAFKA-5800 > URL: https://issues.apache.org/jira/browse/KAFKA-5800 > Project: Kafka > Issue Type: Bug > Affects Versions: 0.10.2.1 > Environment: Windows Server 2012 > Reporter: Ahmed Mohsen > > the server shutdown suddenly with this Exception > {code:java} > [2017-08-28 11:41:09,975] FATAL [Replica Manager on Broker 0]: Error writing > to highwatermark file: (kafka.server.ReplicaManager) > java.nio.file.FileAlreadyExistsException: > D:\tmp\kafka-logs\replication-offset-checkpoint.tmp -> > D:\tmp\kafka-logs\replication-offset-checkpoint > at > sun.nio.fs.WindowsException.translateToIOException(WindowsException.java:81) > at > sun.nio.fs.WindowsException.rethrowAsIOException(WindowsException.java:97) > at sun.nio.fs.WindowsFileCopy.move(WindowsFileCopy.java:387) > at > sun.nio.fs.WindowsFileSystemProvider.move(WindowsFileSystemProvider.java:287) > at java.nio.file.Files.move(Files.java:1395) > at > org.apache.kafka.common.utils.Utils.atomicMoveWithFallback(Utils.java:711) > at kafka.server.OffsetCheckpoint.write(OffsetCheckpoint.scala:76) > at > kafka.server.ReplicaManager.$anonfun$checkpointHighWatermarks$5(ReplicaManager.scala:946) > at > kafka.server.ReplicaManager.$anonfun$checkpointHighWatermarks$5$adapted(ReplicaManager.scala:943) > at kafka.server.ReplicaManager$$Lambda$862/1600997378.apply(Unknown > Source) > at > scala.collection.TraversableLike$WithFilter.$anonfun$foreach$1(TraversableLike.scala:789) > at > scala.collection.TraversableLike$WithFilter$$Lambda$234/1781493632.apply(Unknown > Source) > at scala.collection.immutable.Map$Map1.foreach(Map.scala:120) > at > scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:788) > at > kafka.server.ReplicaManager.checkpointHighWatermarks(ReplicaManager.scala:943) > at > kafka.server.ReplicaManager.$anonfun$startHighWaterMarksCheckPointThread$1(ReplicaManager.scala:163) > at > kafka.server.ReplicaManager$$Lambda$854/1298788908.apply$mcV$sp(Unknown > Source) > at > kafka.utils.KafkaScheduler.$anonfun$schedule$2(KafkaScheduler.scala:110) > at > kafka.utils.KafkaScheduler$$Lambda$269/137460818.apply$mcV$sp(Unknown Source) > at kafka.utils.CoreUtils$$anon$1.run(CoreUtils.scala:57) > at > java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) > at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) > at > java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) > at > java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) > at java.lang.Thread.run(Thread.java:745) > Suppressed: java.nio.file.AccessDeniedException: > D:\tmp\kafka-logs\replication-offset-checkpoint.tmp -> > D:\tmp\kafka-logs\replication-offset-checkpoint > at > sun.nio.fs.WindowsException.translateToIOException(WindowsException.java:83) > at > sun.nio.fs.WindowsException.rethrowAsIOException(WindowsException.java:97) > at sun.nio.fs.WindowsFileCopy.move(WindowsFileCopy.java:301) > at > sun.nio.fs.WindowsFileSystemProvider.move(WindowsFileSystemProvider.java:287) > at java.nio.file.Files.move(Files.java:1395) > at > org.apache.kafka.common.utils.Utils.atomicMoveWithFallback(Utils.java:708) > ... 21 more > {code} -- This message was sent by Atlassian JIRA (v6.4.14#64029)