卡夫卡Vertica的消費者和拒絕表

我看到使用Vertica的卡夫卡消費者很奇怪的現象：卡夫卡Vertica的消費者和拒絕表

2016-07-27 04:22:17.307 com.vertica.solutions.kafka.scheduler.StreamCoordinator::Main [INFO] Starting frame @ 2016-07-27 04:22:17.307 
2016-07-27 04:22:17.330 com.vertica.solutions.kafka.scheduler.FrameScheduler::Main [INFO] Starting compute batches for new Frame. 
2016-07-27 04:22:17.431 com.vertica.solutions.kafka.scheduler.FrameScheduler::Main [INFO] Completed computing batch set for current Frame. 
2016-07-27 04:22:17.469 com.vertica.solutions.kafka.scheduler.LaneWorker::Lane Worker 2 ("openx"."requests"[email protected] 04:22:17.431) [ERROR] Rolling back MB: [Vertica][VJDBC](4213) ROLLBACK: Object "requests_rej" already exists 
java.sql.SQLSyntaxErrorException: [Vertica][VJDBC](4213) ROLLBACK: Object "requests_rej" already exists 
    at com.vertica.util.ServerErrorData.buildException(Unknown Source) 
    at com.vertica.dataengine.VResultSet.fetchChunk(Unknown Source) 
    at com.vertica.dataengine.VResultSet.initialize(Unknown Source) 
    at com.vertica.dataengine.VQueryExecutor.readExecuteResponse(Unknown Source) 
    at com.vertica.dataengine.VQueryExecutor.handleExecuteResponse(Unknown Source) 
    at com.vertica.dataengine.VQueryExecutor.execute(Unknown Source) 
    at com.vertica.jdbc.common.SPreparedStatement.executeWithParams(Unknown Source) 
    at com.vertica.jdbc.common.SPreparedStatement.executeUpdate(Unknown Source) 
    at com.vertica.solutions.kafka.scheduler.MicroBatch.execute(MicroBatch.java:193) 
    at com.vertica.solutions.kafka.scheduler.LaneWorker.run(LaneWorker.java:69) 
    at java.lang.Thread.run(Thread.java:745) 
Caused by: com.vertica.support.exceptions.SyntaxErrorException: [Vertica][VJDBC](4213) ROLLBACK: Object "requests_rej" already exists 
    ... 11 more 
2016-07-27 04:22:17.469 com.vertica.solutions.kafka.scheduler.LaneWorker::Lane Worker 2 [INFO] Lane Worker 2 waiting for batch... 
2016-07-27 04:22:17.469 com.vertica.solutions.kafka.scheduler.StreamCoordinator::Main [INFO] Sleeping for 9838 milliseconds until 2016-07-27 04:22:27.307. Started frame @ 2016-07-27 04:22:17.307. 
2016-07-27 04:22:27.308 com.vertica.solutions.kafka.scheduler.StreamCoordinator::Main [INFO] Starting frame @ 2016-07-27 04:22:27.307 
2016-07-27 04:22:27.331 com.vertica.solutions.kafka.scheduler.FrameScheduler::Main [INFO] Starting compute batches for new Frame. 
2016-07-27 04:22:27.427 com.vertica.solutions.kafka.scheduler.FrameScheduler::Main [INFO] Completed computing batch set for current Frame.

我一樣的文件說，但在寫入Vertica的看到這個錯誤！爲什麼我看到它？我該如何解決它？

來源

2016-07-27 juise

你好，你似乎使用相同的對象爲多個創建stmt，請嘗試ti使用參數作爲tbl名稱，並看到結果eh：table_tej $ version123 –

錯誤明確提到

對象「requests_rej」已經存在

嘗試下探對象和運行工作。

來源

2016-07-27 12:58:36 NitheshKHP

這個明顯的解決方案，當然，我做了幾次。沒有幫助！請注意，該表由kafka調度程序在vertica中自動創建。 – juise

卡夫卡Vertica的消費者和拒絕表

回答

相關問題