File tree Expand file tree Collapse file tree
multi-stage-query/src/main/java/org/apache/druid/msq/indexing Expand file tree Collapse file tree Original file line number Diff line number Diff line change 2929import org .apache .druid .msq .input .table .TableInputSpec ;
3030import org .apache .druid .msq .util .MultiStageQueryContext ;
3131import org .apache .druid .query .QueryContext ;
32+ import org .apache .druid .rpc .StandardRetryPolicy ;
3233
3334import java .util .List ;
3435
@@ -42,7 +43,10 @@ public class IndexerTableInputSpecSlicerProvider implements InputSpecSlicerProvi
4243 @ Inject
4344 public IndexerTableInputSpecSlicerProvider (CoordinatorClient coordinatorClient )
4445 {
45- this .coordinatorClient = coordinatorClient ;
46+ // Use the "aboutAnHour" retry policy, same as the one used in the TaskToolboxFactory. This prevents
47+ // long-running tasks from failing if there are Coordinator/Overlord problems. Calls will still fail
48+ // eventually if problems persist.
49+ this .coordinatorClient = coordinatorClient .withRetryPolicy (StandardRetryPolicy .aboutAnHour ());
4650 }
4751
4852 @ Override
You can’t perform that action at this time.
0 commit comments