2016-07-27 11 views
0

カフカの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にこのエラーを参照してください!なぜ私はそれを見ますか?どうすれば修正できますか?

+0

こんにちは、stmtを複数作成するために同じオブジェクトを使用しているようですが、tbl名としてパラメータを使用して、結果を確認してください:table_tej $ version123 –

答えて

0

エラーが明確に

オブジェクト "requests_rej" はすでに

がオブジェクトをドロップすると、あなたの仕事を実行してみ存在していることに言及しています。

+0

この明らかな解決策はもちろんです。助けにならない!このテーブルは、カフカスケジューラによって自動的に作成されたことに注意してください。 – juise

関連する問題