Skip to content

Commit

Permalink
Revert "Add integration tests for concurrent append and replace (apac…
Browse files Browse the repository at this point in the history
…he#16755)" (apache#17000)

This reverts commit 70bad94.
  • Loading branch information
AmatyaAvadhanula authored and edgar2020 committed Sep 5, 2024
1 parent 1727cf3 commit ce3184e
Show file tree
Hide file tree
Showing 4 changed files with 0 additions and 547 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,6 @@
import org.apache.druid.indexer.TaskStatusPlus;
import org.apache.druid.indexer.report.IngestionStatsAndErrorsTaskReport;
import org.apache.druid.indexer.report.TaskReport;
import org.apache.druid.indexing.overlord.http.TaskLockResponse;
import org.apache.druid.indexing.overlord.http.TaskPayloadResponse;
import org.apache.druid.indexing.overlord.supervisor.SupervisorStateManager;
import org.apache.druid.java.util.common.ISE;
Expand Down Expand Up @@ -361,31 +360,6 @@ public Map<String, List<Interval>> getLockedIntervals(List<LockFilterPolicy> loc
}
}

public TaskLockResponse getActiveLocks(List<LockFilterPolicy> lockFilterPolicies)
{
try {
String jsonBody = jsonMapper.writeValueAsString(lockFilterPolicies);

StatusResponseHolder response = httpClient.go(
new Request(HttpMethod.POST, new URL(getIndexerURL() + "activeLocks"))
.setContent(
"application/json",
StringUtils.toUtf8(jsonBody)
),
StatusResponseHandler.getInstance()
).get();
return jsonMapper.readValue(
response.getContent(),
new TypeReference<TaskLockResponse>()
{
}
);
}
catch (Exception e) {
throw new RuntimeException(e);
}
}

public void waitUntilTaskCompletes(final String taskID)
{
waitUntilTaskCompletes(taskID, ITRetryUtil.DEFAULT_RETRY_SLEEP, ITRetryUtil.DEFAULT_RETRY_COUNT);
Expand Down
Loading

0 comments on commit ce3184e

Please sign in to comment.