Skip to content
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.

Sign up for GitHub

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

Jump to bottom

[CI] MonotonicClockTests testMonotonicityWithSystemClock failing #108507

Closed
luigidellaquila opened this issue May 10, 2024 · 1 comment · Fixed by #108508
Closed

[CI] MonotonicClockTests testMonotonicityWithSystemClock failing #108507

luigidellaquila opened this issue May 10, 2024 · 1 comment · Fixed by #108508
Assignees
@prwhelan
Labels
:ml/Transform Transform needs:risk Requires assignment of a risk label (low, medium, blocker) Team:ML Meta label for the ML team >test-failure Triaged test failures from CI

Comments

@luigidellaquila
Copy link
Contributor

Build scan:
https://gradle-enterprise.elastic.co/s/6q3ezdpqppbts/tests/:x-pack:plugin:transform:test/org.elasticsearch.xpack.transform.transforms.scheduling.MonotonicClockTests/testMonotonicityWithSystemClock

Reproduction line:

./gradlew ':x-pack:plugin:transform:test' --tests "org.elasticsearch.xpack.transform.transforms.scheduling.MonotonicClockTests.testMonotonicityWithSystemClock" -Dtests.seed=FC9728F4DBFCFB30 -Dtests.locale=th-TH -Dtests.timezone=UTC -Druntime.java=21

Applicable branches:
main

Reproduces locally?:
No

Failure history:
Failure dashboard for org.elasticsearch.xpack.transform.transforms.scheduling.MonotonicClockTests#testMonotonicityWithSystemClock

Failure excerpt:

java.lang.AssertionError: 
Expected: an empty collection
     but: <[LEAK: resource was not cleaned up before it was garbage-collected.
Recent access records: 
Created at:
	in [elasticsearch[testHandleBulkResponseWithNoFailures][generic][T#1]][testHandleBulkResponseWithNoFailures]
	org.elasticsearch.search.SearchHit.<init>(SearchHit.java:194)
	org.elasticsearch.search.SearchHit.<init>(SearchHit.java:126)
	org.elasticsearch.search.SearchHit.<init>(SearchHit.java:122)
	org.elasticsearch.search.SearchHit.<init>(SearchHit.java:118)
	org.elasticsearch.search.SearchHit.<init>(SearchHit.java:114)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests.lambda$returnHit$26(TransformIndexerFailureHandlingTests.java:994)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doNextSearch(TransformIndexerFailureHandlingTests.java:199)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.triggerNextSearch(AsyncTwoPhaseIndexer.java:623)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.nextSearch(AsyncTwoPhaseIndexer.java:610)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.lambda$maybeTriggerAsyncJob$4(AsyncTwoPhaseIndexer.java:233)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$6(TransformIndexer.java:301)
	org.elasticsearch.action.ActionListenerImplementations$ResponseWrappingActionListener.onResponse(ActionListenerImplementations.java:245)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$7(TransformIndexer.java:333)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.common.AbstractCompositeAggFunction.getInitialProgressFromResponse(AbstractCompositeAggFunction.java:206)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$10(TransformIndexer.java:330)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.action.ActionListener.respondAndRelease(ActionListener.java:366)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doGetInitialProgress(TransformIndexerFailureHandlingTests.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$13(TransformIndexer.java:329)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.createCheckpoint(TransformIndexerFailureHandlingTests.java:186)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$14(TransformIndexer.java:311)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$16(TransformIndexer.java:373)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doGetFieldMappings(TransformIndexerFailureHandlingTests.java:287)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$18(TransformIndexer.java:380)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$21(TransformIndexer.java:418)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.onStart(TransformIndexer.java:450)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.lambda$maybeTriggerAsyncJob$5(AsyncTwoPhaseIndexer.java:230)
	org.elasticsearch.common.util.concurrent.ThreadContext$ContextPreservingRunnable.run(ThreadContext.java:917)
	java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	java.base/java.lang.Thread.run(Thread.java:1583), LEAK: resource was not cleaned up before it was garbage-collected.
Recent access records: 
#1:
	in [elasticsearch[testHandleBulkResponseWithNoFailures][generic][T#1]][testHandleBulkResponseWithNoFailures]
	org.elasticsearch.action.search.SearchResponse.<init>(SearchResponse.java:200)
	org.elasticsearch.action.search.SearchResponse.<init>(SearchResponse.java:133)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests.lambda$returnHit$26(TransformIndexerFailureHandlingTests.java:1001)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doNextSearch(TransformIndexerFailureHandlingTests.java:199)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.triggerNextSearch(AsyncTwoPhaseIndexer.java:623)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.nextSearch(AsyncTwoPhaseIndexer.java:610)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.lambda$maybeTriggerAsyncJob$4(AsyncTwoPhaseIndexer.java:233)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$6(TransformIndexer.java:301)
	org.elasticsearch.action.ActionListenerImplementations$ResponseWrappingActionListener.onResponse(ActionListenerImplementations.java:245)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$7(TransformIndexer.java:333)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.common.AbstractCompositeAggFunction.getInitialProgressFromResponse(AbstractCompositeAggFunction.java:206)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$10(TransformIndexer.java:330)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.action.ActionListener.respondAndRelease(ActionListener.java:366)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doGetInitialProgress(TransformIndexerFailureHandlingTests.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$13(TransformIndexer.java:329)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.createCheckpoint(TransformIndexerFailureHandlingTests.java:186)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$14(TransformIndexer.java:311)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$16(TransformIndexer.java:373)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doGetFieldMappings(TransformIndexerFailureHandlingTests.java:287)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$18(TransformIndexer.java:380)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$21(TransformIndexer.java:418)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.onStart(TransformIndexer.java:450)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.lambda$maybeTriggerAsyncJob$5(AsyncTwoPhaseIndexer.java:230)
	org.elasticsearch.common.util.concurrent.ThreadContext$ContextPreservingRunnable.run(ThreadContext.java:917)
	java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	java.base/java.lang.Thread.run(Thread.java:1583)
Created at:
	in [elasticsearch[testHandleBulkResponseWithNoFailures][generic][T#1]][testHandleBulkResponseWithNoFailures]
	org.elasticsearch.search.SearchHits.<init>(SearchHits.java:75)
	org.elasticsearch.search.SearchHits.<init>(SearchHits.java:57)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests.lambda$returnHit$26(TransformIndexerFailureHandlingTests.java:994)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doNextSearch(TransformIndexerFailureHandlingTests.java:199)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.triggerNextSearch(AsyncTwoPhaseIndexer.java:623)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.nextSearch(AsyncTwoPhaseIndexer.java:610)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.lambda$maybeTriggerAsyncJob$4(AsyncTwoPhaseIndexer.java:233)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$6(TransformIndexer.java:301)
	org.elasticsearch.action.ActionListenerImplementations$ResponseWrappingActionListener.onResponse(ActionListenerImplementations.java:245)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$7(TransformIndexer.java:333)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.common.AbstractCompositeAggFunction.getInitialProgressFromResponse(AbstractCompositeAggFunction.java:206)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$10(TransformIndexer.java:330)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.action.ActionListener.respondAndRelease(ActionListener.java:366)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doGetInitialProgress(TransformIndexerFailureHandlingTests.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$13(TransformIndexer.java:329)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.createCheckpoint(TransformIndexerFailureHandlingTests.java:186)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$14(TransformIndexer.java:311)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$16(TransformIndexer.java:373)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doGetFieldMappings(TransformIndexerFailureHandlingTests.java:287)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$18(TransformIndexer.java:380)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$21(TransformIndexer.java:418)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.onStart(TransformIndexer.java:450)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.lambda$maybeTriggerAsyncJob$5(AsyncTwoPhaseIndexer.java:230)
	org.elasticsearch.common.util.concurrent.ThreadContext$ContextPreservingRunnable.run(ThreadContext.java:917)
	java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	java.base/java.lang.Thread.run(Thread.java:1583), LEAK: resource was not cleaned up before it was garbage-collected.
Recent access records: 
Created at:
	in [elasticsearch[testHandleBulkResponseWithNoFailures][generic][T#1]][testHandleBulkResponseWithNoFailures]
	org.elasticsearch.action.search.SearchResponse.<init>(SearchResponse.java:88)
	org.elasticsearch.action.search.SearchResponse.<init>(SearchResponse.java:133)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests.lambda$returnHit$26(TransformIndexerFailureHandlingTests.java:1001)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doNextSearch(TransformIndexerFailureHandlingTests.java:199)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.triggerNextSearch(AsyncTwoPhaseIndexer.java:623)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.nextSearch(AsyncTwoPhaseIndexer.java:610)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.lambda$maybeTriggerAsyncJob$4(AsyncTwoPhaseIndexer.java:233)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$6(TransformIndexer.java:301)
	org.elasticsearch.action.ActionListenerImplementations$ResponseWrappingActionListener.onResponse(ActionListenerImplementations.java:245)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$7(TransformIndexer.java:333)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.common.AbstractCompositeAggFunction.getInitialProgressFromResponse(AbstractCompositeAggFunction.java:206)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$10(TransformIndexer.java:330)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.action.ActionListener.respondAndRelease(ActionListener.java:366)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doGetInitialProgress(TransformIndexerFailureHandlingTests.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$13(TransformIndexer.java:329)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.createCheckpoint(TransformIndexerFailureHandlingTests.java:186)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$14(TransformIndexer.java:311)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$16(TransformIndexer.java:373)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doGetFieldMappings(TransformIndexerFailureHandlingTests.java:287)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$18(TransformIndexer.java:380)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$21(TransformIndexer.java:418)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.onStart(TransformIndexer.java:450)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.lambda$maybeTriggerAsyncJob$5(AsyncTwoPhaseIndexer.java:230)
	org.elasticsearch.common.util.concurrent.ThreadContext$ContextPreservingRunnable.run(ThreadContext.java:917)
	java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	java.base/java.lang.Thread.run(Thread.java:1583), LEAK: resource was not cleaned up before it was garbage-collected.
Recent access records: 
Created at:
	in [elasticsearch[testHandleBulkResponseWithNoFailures][generic][T#1]][testHandleBulkResponseWithNoFailures]
	org.elasticsearch.search.SearchHit.<init>(SearchHit.java:194)
	org.elasticsearch.search.SearchHit.<init>(SearchHit.java:126)
	org.elasticsearch.search.SearchHit.<init>(SearchHit.java:122)
	org.elasticsearch.search.SearchHit.<init>(SearchHit.java:118)
	org.elasticsearch.search.SearchHit.<init>(SearchHit.java:114)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests.lambda$returnHit$26(TransformIndexerFailureHandlingTests.java:994)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doNextSearch(TransformIndexerFailureHandlingTests.java:199)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.triggerNextSearch(AsyncTwoPhaseIndexer.java:623)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.nextSearch(AsyncTwoPhaseIndexer.java:610)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.onBulkResponse(AsyncTwoPhaseIndexer.java:581)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.lambda$onSearchResponse$11(AsyncTwoPhaseIndexer.java:547)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.ClientTransformIndexer.handleBulkResponse(ClientTransformIndexer.java:187)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doNextBulk(TransformIndexerFailureHandlingTests.java:217)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.onSearchResponse(AsyncTwoPhaseIndexer.java:533)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doNextSearch(TransformIndexerFailureHandlingTests.java:200)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.triggerNextSearch(AsyncTwoPhaseIndexer.java:623)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.nextSearch(AsyncTwoPhaseIndexer.java:610)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.lambda$maybeTriggerAsyncJob$4(AsyncTwoPhaseIndexer.java:233)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$6(TransformIndexer.java:301)
	org.elasticsearch.action.ActionListenerImplementations$ResponseWrappingActionListener.onResponse(ActionListenerImplementations.java:245)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$7(TransformIndexer.java:333)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.common.AbstractCompositeAggFunction.getInitialProgressFromResponse(AbstractCompositeAggFunction.java:206)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$10(TransformIndexer.java:330)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.action.ActionListener.respondAndRelease(ActionListener.java:366)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doGetInitialProgress(TransformIndexerFailureHandlingTests.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$13(TransformIndexer.java:329)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.createCheckpoint(TransformIndexerFailureHandlingTests.java:186)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$14(TransformIndexer.java:311)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$16(TransformIndexer.java:373)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doGetFieldMappings(TransformIndexerFailureHandlingTests.java:287)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$18(TransformIndexer.java:380)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$21(TransformIndexer.java:418)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.onStart(TransformIndexer.java:450)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.lambda$maybeTriggerAsyncJob$5(AsyncTwoPhaseIndexer.java:230)
	org.elasticsearch.common.util.concurrent.ThreadContext$ContextPreservingRunnable.run(ThreadContext.java:917)
	java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	java.base/java.lang.Thread.run(Thread.java:1583), LEAK: resource was not cleaned up before it was garbage-collected.
Recent access records: 
#1:
	in [elasticsearch[testHandleBulkResponseWithNoFailures][generic][T#1]][testHandleBulkResponseWithNoFailures]
	org.elasticsearch.action.search.SearchResponse.<init>(SearchResponse.java:200)
	org.elasticsearch.action.search.SearchResponse.<init>(SearchResponse.java:133)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests.lambda$returnHit$26(TransformIndexerFailureHandlingTests.java:1001)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doNextSearch(TransformIndexerFailureHandlingTests.java:199)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.triggerNextSearch(AsyncTwoPhaseIndexer.java:623)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.nextSearch(AsyncTwoPhaseIndexer.java:610)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.onBulkResponse(AsyncTwoPhaseIndexer.java:581)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.lambda$onSearchResponse$11(AsyncTwoPhaseIndexer.java:547)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.ClientTransformIndexer.handleBulkResponse(ClientTransformIndexer.java:187)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doNextBulk(TransformIndexerFailureHandlingTests.java:217)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.onSearchResponse(AsyncTwoPhaseIndexer.java:533)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doNextSearch(TransformIndexerFailureHandlingTests.java:200)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.triggerNextSearch(AsyncTwoPhaseIndexer.java:623)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.nextSearch(AsyncTwoPhaseIndexer.java:610)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.lambda$maybeTriggerAsyncJob$4(AsyncTwoPhaseIndexer.java:233)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$6(TransformIndexer.java:301)
	org.elasticsearch.action.ActionListenerImplementations$ResponseWrappingActionListener.onResponse(ActionListenerImplementations.java:245)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$7(TransformIndexer.java:333)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.common.AbstractCompositeAggFunction.getInitialProgressFromResponse(AbstractCompositeAggFunction.java:206)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$10(TransformIndexer.java:330)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.action.ActionListener.respondAndRelease(ActionListener.java:366)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doGetInitialProgress(TransformIndexerFailureHandlingTests.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$13(TransformIndexer.java:329)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.createCheckpoint(TransformIndexerFailureHandlingTests.java:186)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$14(TransformIndexer.java:311)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$16(TransformIndexer.java:373)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doGetFieldMappings(TransformIndexerFailureHandlingTests.java:287)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$18(TransformIndexer.java:380)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$21(TransformIndexer.java:418)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.onStart(TransformIndexer.java:450)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.lambda$maybeTriggerAsyncJob$5(AsyncTwoPhaseIndexer.java:230)
	org.elasticsearch.common.util.concurrent.ThreadContext$ContextPreservingRunnable.run(ThreadContext.java:917)
	java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	java.base/java.lang.Thread.run(Thread.java:1583)
Created at:
	in [elasticsearch[testHandleBulkResponseWithNoFailures][generic][T#1]][testHandleBulkResponseWithNoFailures]
	org.elasticsearch.search.SearchHits.<init>(SearchHits.java:75)
	org.elasticsearch.search.SearchHits.<init>(SearchHits.java:57)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests.lambda$returnHit$26(TransformIndexerFailureHandlingTests.java:994)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doNextSearch(TransformIndexerFailureHandlingTests.java:199)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.triggerNextSearch(AsyncTwoPhaseIndexer.java:623)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.nextSearch(AsyncTwoPhaseIndexer.java:610)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.onBulkResponse(AsyncTwoPhaseIndexer.java:581)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.lambda$onSearchResponse$11(AsyncTwoPhaseIndexer.java:547)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.ClientTransformIndexer.handleBulkResponse(ClientTransformIndexer.java:187)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doNextBulk(TransformIndexerFailureHandlingTests.java:217)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.onSearchResponse(AsyncTwoPhaseIndexer.java:533)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doNextSearch(TransformIndexerFailureHandlingTests.java:200)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.triggerNextSearch(AsyncTwoPhaseIndexer.java:623)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.nextSearch(AsyncTwoPhaseIndexer.java:610)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.lambda$maybeTriggerAsyncJob$4(AsyncTwoPhaseIndexer.java:233)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$6(TransformIndexer.java:301)
	org.elasticsearch.action.ActionListenerImplementations$ResponseWrappingActionListener.onResponse(ActionListenerImplementations.java:245)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$7(TransformIndexer.java:333)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.common.AbstractCompositeAggFunction.getInitialProgressFromResponse(AbstractCompositeAggFunction.java:206)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$10(TransformIndexer.java:330)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.action.ActionListener.respondAndRelease(ActionListener.java:366)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doGetInitialProgress(TransformIndexerFailureHandlingTests.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$13(TransformIndexer.java:329)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.createCheckpoint(TransformIndexerFailureHandlingTests.java:186)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$14(TransformIndexer.java:311)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$16(TransformIndexer.java:373)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doGetFieldMappings(TransformIndexerFailureHandlingTests.java:287)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$18(TransformIndexer.java:380)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$21(TransformIndexer.java:418)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.onStart(TransformIndexer.java:450)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.lambda$maybeTriggerAsyncJob$5(AsyncTwoPhaseIndexer.java:230)
	org.elasticsearch.common.util.concurrent.ThreadContext$ContextPreservingRunnable.run(ThreadContext.java:917)
	java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	java.base/java.lang.Thread.run(Thread.java:1583), LEAK: resource was not cleaned up before it was garbage-collected.
Recent access records: 
Created at:
	in [elasticsearch[testHandleBulkResponseWithNoFailures][generic][T#1]][testHandleBulkResponseWithNoFailures]
	org.elasticsearch.action.search.SearchResponse.<init>(SearchResponse.java:88)
	org.elasticsearch.action.search.SearchResponse.<init>(SearchResponse.java:133)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests.lambda$returnHit$26(TransformIndexerFailureHandlingTests.java:1001)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doNextSearch(TransformIndexerFailureHandlingTests.java:199)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.triggerNextSearch(AsyncTwoPhaseIndexer.java:623)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.nextSearch(AsyncTwoPhaseIndexer.java:610)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.onBulkResponse(AsyncTwoPhaseIndexer.java:581)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.lambda$onSearchResponse$11(AsyncTwoPhaseIndexer.java:547)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.ClientTransformIndexer.handleBulkResponse(ClientTransformIndexer.java:187)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doNextBulk(TransformIndexerFailureHandlingTests.java:217)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.onSearchResponse(AsyncTwoPhaseIndexer.java:533)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doNextSearch(TransformIndexerFailureHandlingTests.java:200)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.triggerNextSearch(AsyncTwoPhaseIndexer.java:623)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.nextSearch(AsyncTwoPhaseIndexer.java:610)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.lambda$maybeTriggerAsyncJob$4(AsyncTwoPhaseIndexer.java:233)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$6(TransformIndexer.java:301)
	org.elasticsearch.action.ActionListenerImplementations$ResponseWrappingActionListener.onResponse(ActionListenerImplementations.java:245)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$7(TransformIndexer.java:333)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.common.AbstractCompositeAggFunction.getInitialProgressFromResponse(AbstractCompositeAggFunction.java:206)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$10(TransformIndexer.java:330)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.action.ActionListener.respondAndRelease(ActionListener.java:366)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doGetInitialProgress(TransformIndexerFailureHandlingTests.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$13(TransformIndexer.java:329)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.createCheckpoint(TransformIndexerFailureHandlingTests.java:186)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$14(TransformIndexer.java:311)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$16(TransformIndexer.java:373)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doGetFieldMappings(TransformIndexerFailureHandlingTests.java:287)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$18(TransformIndexer.java:380)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$21(TransformIndexer.java:418)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.onStart(TransformIndexer.java:450)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.lambda$maybeTriggerAsyncJob$5(AsyncTwoPhaseIndexer.java:230)
	org.elasticsearch.common.util.concurrent.ThreadContext$ContextPreservingRunnable.run(ThreadContext.java:917)
	java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	java.base/java.lang.Thread.run(Thread.java:1583), LEAK: resource was not cleaned up before it was garbage-collected.
Recent access records: 
Created at:
	in [elasticsearch[testHandleBulkResponseWithIrrecoverableFailures][generic][T#1]][testHandleBulkResponseWithIrrecoverableFailures]
	org.elasticsearch.search.SearchHit.<init>(SearchHit.java:194)
	org.elasticsearch.search.SearchHit.<init>(SearchHit.java:126)
	org.elasticsearch.search.SearchHit.<init>(SearchHit.java:122)
	org.elasticsearch.search.SearchHit.<init>(SearchHit.java:118)
	org.elasticsearch.search.SearchHit.<init>(SearchHit.java:114)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests.lambda$returnHit$26(TransformIndexerFailureHandlingTests.java:994)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doNextSearch(TransformIndexerFailureHandlingTests.java:199)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.triggerNextSearch(AsyncTwoPhaseIndexer.java:623)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.nextSearch(AsyncTwoPhaseIndexer.java:610)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.lambda$maybeTriggerAsyncJob$4(AsyncTwoPhaseIndexer.java:233)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$6(TransformIndexer.java:301)
	org.elasticsearch.action.ActionListenerImplementations$ResponseWrappingActionListener.onResponse(ActionListenerImplementations.java:245)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$7(TransformIndexer.java:333)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.common.AbstractCompositeAggFunction.getInitialProgressFromResponse(AbstractCompositeAggFunction.java:206)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$10(TransformIndexer.java:330)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.action.ActionListener.respondAndRelease(ActionListener.java:366)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doGetInitialProgress(TransformIndexerFailureHandlingTests.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$13(TransformIndexer.java:329)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.createCheckpoint(TransformIndexerFailureHandlingTests.java:186)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$14(TransformIndexer.java:311)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$16(TransformIndexer.java:373)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doGetFieldMappings(TransformIndexerFailureHandlingTests.java:287)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$18(TransformIndexer.java:380)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$21(TransformIndexer.java:418)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.onStart(TransformIndexer.java:450)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.lambda$maybeTriggerAsyncJob$5(AsyncTwoPhaseIndexer.java:230)
	org.elasticsearch.common.util.concurrent.ThreadContext$ContextPreservingRunnable.run(ThreadContext.java:917)
	java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	java.base/java.lang.Thread.run(Thread.java:1583), LEAK: resource was not cleaned up before it was garbage-collected.
Recent access records: 
#1:
	in [elasticsearch[testHandleBulkResponseWithIrrecoverableFailures][generic][T#1]][testHandleBulkResponseWithIrrecoverableFailures]
	org.elasticsearch.action.search.SearchResponse.<init>(SearchResponse.java:200)
	org.elasticsearch.action.search.SearchResponse.<init>(SearchResponse.java:133)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests.lambda$returnHit$26(TransformIndexerFailureHandlingTests.java:1001)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doNextSearch(TransformIndexerFailureHandlingTests.java:199)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.triggerNextSearch(AsyncTwoPhaseIndexer.java:623)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.nextSearch(AsyncTwoPhaseIndexer.java:610)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.lambda$maybeTriggerAsyncJob$4(AsyncTwoPhaseIndexer.java:233)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$6(TransformIndexer.java:301)
	org.elasticsearch.action.ActionListenerImplementations$ResponseWrappingActionListener.onResponse(ActionListenerImplementations.java:245)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$7(TransformIndexer.java:333)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.common.AbstractCompositeAggFunction.getInitialProgressFromResponse(AbstractCompositeAggFunction.java:206)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$10(TransformIndexer.java:330)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.action.ActionListener.respondAndRelease(ActionListener.java:366)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doGetInitialProgress(TransformIndexerFailureHandlingTests.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$13(TransformIndexer.java:329)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.createCheckpoint(TransformIndexerFailureHandlingTests.java:186)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$14(TransformIndexer.java:311)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$16(TransformIndexer.java:373)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doGetFieldMappings(TransformIndexerFailureHandlingTests.java:287)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$18(TransformIndexer.java:380)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$21(TransformIndexer.java:418)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.onStart(TransformIndexer.java:450)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.lambda$maybeTriggerAsyncJob$5(AsyncTwoPhaseIndexer.java:230)
	org.elasticsearch.common.util.concurrent.ThreadContext$ContextPreservingRunnable.run(ThreadContext.java:917)
	java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	java.base/java.lang.Thread.run(Thread.java:1583)
Created at:
	in [elasticsearch[testHandleBulkResponseWithIrrecoverableFailures][generic][T#1]][testHandleBulkResponseWithIrrecoverableFailures]
	org.elasticsearch.search.SearchHits.<init>(SearchHits.java:75)
	org.elasticsearch.search.SearchHits.<init>(SearchHits.java:57)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests.lambda$returnHit$26(TransformIndexerFailureHandlingTests.java:994)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doNextSearch(TransformIndexerFailureHandlingTests.java:199)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.triggerNextSearch(AsyncTwoPhaseIndexer.java:623)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.nextSearch(AsyncTwoPhaseIndexer.java:610)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.lambda$maybeTriggerAsyncJob$4(AsyncTwoPhaseIndexer.java:233)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$6(TransformIndexer.java:301)
	org.elasticsearch.action.ActionListenerImplementations$ResponseWrappingActionListener.onResponse(ActionListenerImplementations.java:245)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$7(TransformIndexer.java:333)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.common.AbstractCompositeAggFunction.getInitialProgressFromResponse(AbstractCompositeAggFunction.java:206)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$10(TransformIndexer.java:330)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.action.ActionListener.respondAndRelease(ActionListener.java:366)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doGetInitialProgress(TransformIndexerFailureHandlingTests.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$13(TransformIndexer.java:329)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.createCheckpoint(TransformIndexerFailureHandlingTests.java:186)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$14(TransformIndexer.java:311)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$16(TransformIndexer.java:373)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doGetFieldMappings(TransformIndexerFailureHandlingTests.java:287)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$18(TransformIndexer.java:380)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$21(TransformIndexer.java:418)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.onStart(TransformIndexer.java:450)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.lambda$maybeTriggerAsyncJob$5(AsyncTwoPhaseIndexer.java:230)
	org.elasticsearch.common.util.concurrent.ThreadContext$ContextPreservingRunnable.run(ThreadContext.java:917)
	java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	java.base/java.lang.Thread.run(Thread.java:1583), LEAK: resource was not cleaned up before it was garbage-collected.
Recent access records: 
Created at:
	in [elasticsearch[testHandleBulkResponseWithIrrecoverableFailures][generic][T#1]][testHandleBulkResponseWithIrrecoverableFailures]
	org.elasticsearch.action.search.SearchResponse.<init>(SearchResponse.java:88)
	org.elasticsearch.action.search.SearchResponse.<init>(SearchResponse.java:133)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests.lambda$returnHit$26(TransformIndexerFailureHandlingTests.java:1001)
	org.elasticsearch.xpack.transform.transforms.TransformIndexerFailureHandlingTests$MockedTransformIndexer.doNextSearch(TransformIndexerFailureHandlingTests.java:199)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.triggerNextSearch(AsyncTwoPhaseIndexer.java:623)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.nextSearch(AsyncTwoPhaseIndexer.java:610)
	org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer.lambda$maybeTriggerAsyncJob$4(AsyncTwoPhaseIndexer.java:233)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:248)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$6(TransformIndexer.java:301)
	org.elasticsearch.action.ActionListenerImplementations$ResponseWrappingActionListener.onResponse(ActionListenerImplementations.java:245)
	org.elasticsearch.xpack.transform.transforms.TransformIndexer.lambda$onStart$7(TransformIndexer.java:333)
	org.elasticsearch.action.ActionListener$2.onResponse(ActionListener.java:...
@luigidellaquila luigidellaquila added :ml/Transform Transform >test-failure Triaged test failures from CI labels May 10, 2024
@elasticsearchmachine
Copy link
Collaborator

Pinging @elastic/ml-core (Team:ML)

@elasticsearchmachine elasticsearchmachine added Team:ML Meta label for the ML team needs:risk Requires assignment of a risk label (low, medium, blocker) labels May 10, 2024
@prwhelan prwhelan self-assigned this May 10, 2024
prwhelan added a commit to prwhelan/elasticsearch that referenced this issue May 10, 2024
@prwhelan
[Transform] Use unpooled SearchHits in tests
2c98c59 
Fix elastic#108507
@prwhelan prwhelan mentioned this issue May 10, 2024
Merged
prwhelan added a commit that referenced this issue May 10, 2024
@prwhelan
[Transform] Use unpooled SearchHits in tests (#108508)
b6874a5 
Fix #108507
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees

@prwhelan prwhelan

Labels
:ml/Transform Transform needs:risk Requires assignment of a risk label (low, medium, blocker) Team:ML Meta label for the ML team >test-failure Triaged test failures from CI
Projects
None yet
Milestone
No milestone
Development

Successfully merging a pull request may close this issue.

[Transform] Use unpooled SearchHits in tests prwhelan/elasticsearch
3 participants
@luigidellaquila @prwhelan @elasticsearchmachine