ROLLBACK: Object "xxx_rej" already exists

juise

Hello! Recently, iin log files observer the follow strange error:

 

 

016-07-22 08:23:51.658 com.vertica.solutions.kafka.scheduler.StreamCoordinator::Main  [INFO] Sleeping for 9834 milliseconds until 2016-07-22 08:24:01.492. Started frame @ 2016-07-22 08:23:51.492.
2016-07-22 08:24:01.492 com.vertica.solutions.kafka.scheduler.StreamCoordinator::Main  [INFO] Starting frame @ 2016-07-22 08:24:01.492
2016-07-22 08:24:01.518 com.vertica.solutions.kafka.scheduler.FrameScheduler::Main  [INFO] Starting compute batches for new Frame.
2016-07-22 08:24:01.625 com.vertica.solutions.kafka.scheduler.FrameScheduler::Main  [INFO] Completed computing batch set for current Frame.
2016-07-22 08:24:11.907 com.vertica.solutions.kafka.scheduler.LaneWorker::Lane Worker 2  [INFO] Lane Worker 2 waiting for batch...
2016-07-22 08:24:11.907 com.vertica.solutions.kafka.scheduler.StreamCoordinator::Main  [INFO] Starting frame @ 2016-07-22 08:24:11.907
2016-07-22 08:24:11.953 com.vertica.solutions.kafka.scheduler.FrameScheduler::Main  [INFO] Starting compute batches for new Frame.
2016-07-22 08:24:12.065 com.vertica.solutions.kafka.scheduler.FrameScheduler::Main  [INFO] Completed computing batch set for current Frame.
2016-07-22 08:24:12.095 com.vertica.solutions.kafka.scheduler.LaneWorker::Lane Worker 2 ("openx"."requests"-CREATE@2016-07-22 08:24:12.065) [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-22 08:24:12.096 com.vertica.solutions.kafka.scheduler.LaneWorker::Lane Worker 2  [INFO] Lane Worker 2 waiting for batch...

2016-07-22 08:24:12.096 com.vertica.solutions.kafka.scheduler.StreamCoordinator::Main  [INFO] Sleeping for 9811 milliseconds until 2016-07-22 08:24:21.907. Started frame @ 2016-07-22 08:24:11.907.
2016-07-22 08:24:21.907 com.vertica.solutions.kafka.scheduler.StreamCoordinator::Main  [INFO] Starting frame @ 2016-07-22 08:24:21.907
2016-07-22 08:24:21.932 com.vertica.solutions.kafka.scheduler.StreamCoordinator::Main  [INFO] Refreshing Scheduler (refresh interval reached).
2016-07-22 08:24:21.932 com.vertica.solutions.kafka.scheduler.StreamCoordinator::Main  [INFO] Setup trial 0
2016-07-22 08:24:22.009 com.vertica.solutions.kafka.scheduler.StreamCoordinator::Main  [INFO] Received configuration details; frame duration: 10000, refresh interval 300000, eof timeout interval: 0, resource pool: kafka_default_pool, new topic policy: FAIR
2016-07-22 08:24:22.028 com.vertica.solutions.kafka.scheduler.StreamCoordinator::Main  [INFO] Received configuration details; planned concurrency: 2, max concurrency: 0, max execution parallelism: 32. Setting lane count: 2
2016-07-22 08:24:22.031 com.vertica.solutions.kafka.scheduler.FrameScheduler::Main  [INFO] Starting compute batches for new Frame.
2016-07-22 08:24:22.135 com.vertica.solutions.kafka.scheduler.FrameScheduler::Main  [INFO] Completed computing batch set for current Frame.
2016-07-22 08:24:32.342 com.vertica.solutions.kafka.scheduler.LaneWorker::Lane Worker 2  [INFO] Lane Worker 2 waiting for batch...
2016-07-22 08:24:32.342 com.vertica.solutions.kafka.scheduler.StreamCoordinator::Main  [INFO] Starting frame @ 2016-07-22 08:24:32.342
2016-07-22 08:24:32.393 com.vertica.solutions.kafka.scheduler.FrameScheduler::Main  [INFO] Starting compute batches for new Frame.
2016-07-22 08:24:32.499 com.vertica.solutions.kafka.scheduler.FrameScheduler::Main  [INFO] Completed computing batch set for current Frame.
2016-07-22 08:24:32.532 com.vertica.solutions.kafka.scheduler.LaneWorker::Lane Worker 2 ("openx"."requests"-CREATE@2016-07-22 08:24:32.499) [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-22 08:24:32.533 com.vertica.solutions.kafka.scheduler.LaneWorker::Lane Worker 2  [INFO] Lane Worker 2 waiting for batch...

 

Could anyone help me please?

SruthiA

How are you trying to ingest data from kafka. Is it via script?

juise

I do it by Manual - https://my.vertica.com/docs/7.2.x/PDF/HP_Vertica_7.2.x_Integrating_Apache_Kafka.pdf, e.g. through script "vkconfig" which run Java Class - com.vertica.solutions.kafka.Launcher

SruthiA

did you create the object requests_rej before running vkconfig?

juise

No, it was created by vkconfig, and after this error I several times remove it by hand, but it appear again and again. After I remove all kafka_config schema and recreate scheduler/topic via vkconfig, everything goes fine, but I little bit nervous that this situation can happens again.