Hi,

In order to get it work you can turn off csv-reporter.

On Thu, Feb 5, 2015 at 1:06 PM, Xinyi Su <xiny...@gmail.com> wrote:

> Hi,
>
> Today I updated Kafka cluster from 0.8.2-beta to 0.8.2.0 and run kafka
> producer performance test.
>
> The test cannot continue because of some exceptions thrown which does not
> occur at 0.8.2-beta. My perf library is kafka-perf_2.9.2-0.8.0.jar which is
> the latest version on maven repository.
>
> -bash-4.1$ bin/kafka-producer-perf-test.sh   --broker-list <broker list>
> --topics PerfTopic22 --sync --initial-message-id 1 --messages 200000
> --csv-reporter-enabled --metrics-dir /tmp/PerfTopic22_1
> --message-send-gap-ms 20 --request-num-acks -1 --batch-size 1
>
> java.io.IOException: Unable to create
> /tmp/PerfTopic22_1/ProducerRequestSize.csv
> at
>
> com.yammer.metrics.reporting.CsvReporter.createStreamForMetric(CsvReporter.java:141)
> at
>
> com.yammer.metrics.reporting.CsvReporter.getPrintStream(CsvReporter.java:257)
> at com.yammer.metrics.reporting.CsvReporter.access$000(CsvReporter.java:22)
> at
> com.yammer.metrics.reporting.CsvReporter$1.getStream(CsvReporter.java:156)
> at
>
> com.yammer.metrics.reporting.CsvReporter.processHistogram(CsvReporter.java:194)
> at
>
> com.yammer.metrics.reporting.CsvReporter.processHistogram(CsvReporter.java:22)
> at com.yammer.metrics.core.Histogram.processWith(Histogram.java:231)
> at com.yammer.metrics.reporting.CsvReporter.run(CsvReporter.java:163)
> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
> at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:304)
> at
>
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:178)
> at
>
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
> 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)
>



-- 
Regards,
Tao

Reply via email to