Kafka vertica Verbraucher und Ausleittisch

Ich sehe sehr seltsames Verhalten mit vertica kafka Verbraucher:Kafka vertica Verbraucher und Ausleittisch

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.

ich als Dokumentation zu tun, sagt, aber beim Schreiben in vertica sehen diesen Fehler! Warum sehe ich es? Wie kann ich es reparieren?

Quelle

2016-07-27 juise

Hallo, es scheint, dass Sie das gleiche Objekt für mehrere create stmt verwenden, versuchen Sie, einen Parameter als Tabellenname verwenden und sehen Sie das Ergebnis eh: table_tej $ version123 –

Der Fehler erwähnt deutlich, dass

Objekt "requests_rej" existiert bereits

Versuchen Sie das Objekt löschen und Ihre Arbeit ausgeführt wird.

Quelle

2016-07-27 12:58:36 NitheshKHP

Diese offensichtliche Lösung, natürlich habe ich es mehrmals getan. Hilft nicht! Beachten Sie, dass diese Tabelle automatisch von kafka scheduler in vertica erstellt wird. – juise

Kafka vertica Verbraucher und Ausleittisch

Antwort

Verwandte Themen