Unable to persist because of slashes. Is there a way to recover?

Exception in thread “plumber_persist_1” java.lang.RuntimeException: java.io.IOException: Unable to create temporary file, /tmp/filePeon5723717161909455496ctp:/count/hit.header at com.google.common.base.Throwables.propagate(Throwables.java:160) at io.druid.segment.realtime.plumber.RealtimePlumber.persistHydrant(RealtimePlumber.java:1049) at io.druid.segment.realtime.plumber.RealtimePlumber$3.doRun(RealtimePlumber.java:445) at io.druid.common.guava.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:42) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) at java.lang.Thread.run(Thread.java:745) Caused by: java.io.IOException: Unable to create temporary file, /tmp/filePeon5723717161909455496ctp:/count/hit.header at java.io.File$TempDirectory.generateFile(File.java:1898) at java.io.File.createTempFile(File.java:1987) at java.io.File.createTempFile(File.java:2040) at io.druid.segment.data.TmpFileIOPeon.makeOutputStream(TmpFileIOPeon.java:55) at io.druid.segment.data.GenericIndexedWriter.open(GenericIndexedWriter.java:68) at io.druid.segment.IndexMerger.makeIndexFiles(IndexMerger.java:657) at io.druid.segment.IndexMerger.merge(IndexMerger.java:421) at io.druid.segment.IndexMerger.persist(IndexMerger.java:193) at io.druid.segment.IndexMerger.persist(IndexMerger.java:159) at io.druid.segment.realtime.plumber.RealtimePlumber.persistHydrant(RealtimePlumber.java:1028) … 5 more

``


I think it's related to this https://github.com/druid-io/druid/issues/2370. We need to put a check on our producer. However, current the task cannot be closed because of that error. Is there a way to recover this? Or we just need to cancel the task and reindex?

Cancel and reindex.