-
Notifications
You must be signed in to change notification settings - Fork 30
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Can't get more results because the continuous query has failed already. Most likely this is because the query was cancelled #456
Comments
Another error is: "ERROR Operation UNLOAD_20221111-085837-498980 interrupted, waiting for termination." Replaying from checkpoint file: /data/ptdl_qlrr/logs/UNLOAD_20221111-080630-863209/checkpoint.csv. |
Dear dsbulk team,
I have the following error when I use dsbulk 1.10 to unload data from DSE Analytics nodes:
"Can't get more results because the continuous query has failed already. Most likely this is because the query was cancelled."
Please help me to solve this.
Many thanks,
Ha Nguyen
2022-11-11 08:06:30 WARN Replaying from checkpoint file: /data/ptdl_qlrr/logs/UNLOAD_20221111-074333-416813/checkpoint.csv.
2022-11-11 08:06:30 WARN Record metrics will reflect totals from the previous operation; other metrics won't be affected.
2022-11-11 08:06:30 WARN Only errors and rejected records generated by the current operation will be reported in its log files.
2022-11-11 08:06:31 INFO Username and password provided but auth provider not specified, inferring PlainTextAuthProvider
2022-11-11 08:06:31 INFO Operation directory: /data/ptdl_qlrr/logs/UNLOAD_20221111-080630-863209
2022-11-11 08:48:32 ERROR Operation UNLOAD_20221111-080630-863209 failed: Can't get more results because the continuous query has failed already. Most likely this is because the query was cancelled.
java.util.concurrent.CancellationException: Can't get more results because the continuous query has failed already. Most likely this is because the query was cancelled
at com.datastax.dse.driver.internal.core.cql.continuous.ContinuousRequestHandlerBase$NodeResponseCallback.cancelledResultSetFuture(ContinuousRequestHandlerBase.java:1548)
at com.datastax.dse.driver.internal.core.cql.continuous.ContinuousRequestHandlerBase$NodeResponseCallback.dequeueOrCreatePending(ContinuousRequestHandlerBase.java:1244)
at com.datastax.dse.driver.internal.core.cql.continuous.ContinuousRequestHandlerBase.lambda$fetchNextPage$2(ContinuousRequestHandlerBase.java:306)
at com.datastax.dse.driver.internal.core.cql.continuous.ContinuousRequestHandlerBase.fetchNextPage(ContinuousRequestHandlerBase.java:300) [3 skipped]
at com.datastax.dse.driver.internal.core.cql.continuous.DefaultContinuousAsyncResultSet.fetchNextPage(DefaultContinuousAsyncResultSet.java:102)
at com.datastax.oss.dsbulk.executor.api.subscription.ResultSubscription$Page.nextPage(ResultSubscription.java:585)
at com.datastax.oss.dsbulk.executor.api.subscription.ResultSubscription.fetchNextPage(ResultSubscription.java:353)
at com.datastax.oss.dsbulk.executor.api.subscription.ResultSubscription.lambda$fetchNextPage$3(ResultSubscription.java:392)
at com.datastax.oss.dsbulk.executor.api.subscription.ResultSubscription.dequeue(ResultSubscription.java:450) [4 skipped]
at com.datastax.oss.dsbulk.executor.api.subscription.ResultSubscription.tryNext(ResultSubscription.java:309)
Suppressed: java.lang.Exception: #block terminated with an error
at com.datastax.oss.dsbulk.workflow.unload.UnloadWorkflow.execute(UnloadWorkflow.java:208) [2 skipped]
at com.datastax.oss.dsbulk.runner.WorkflowThread.run(WorkflowThread.java:53)
2022-11-11 08:58:34 INFO Final stats:
2022-11-11 08:58:34 INFO Errors are detailed in the following file(s): unload-errors.log
2022-11-11 08:58:34 INFO Checkpoints for the current operation were written to checkpoint.csv.
2022-11-11 08:58:34 INFO To resume the current operation, re-run it with the same settings, and add the following command line flag:
2022-11-11 08:58:34 INFO --dsbulk.log.checkpoint.file=/data/ptdl_qlrr/logs/UNLOAD_20221111-080630-863209/checkpoint.csv
┆Issue is synchronized with this Jira Task by Unito
The text was updated successfully, but these errors were encountered: