Skip to content
This repository was archived by the owner on Nov 11, 2022. It is now read-only.
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -211,6 +211,20 @@ public Dataflow create(PipelineOptions options) {
int getNumberOfWorkerHarnessThreads();
void setNumberOfWorkerHarnessThreads(int value);

/**
* If {@literal true}, save a heap dump before killing a thread or process which is GC
* thrashing or out of memory. The location of the heap file will either be echoed back
* to the user, or the user will be given the opportunity to download the heap file.
*
* <p>
* CAUTION: Heap dumps can of comparable size to the default boot disk. Consider increasing
* the boot disk size before setting this flag to true.
*/
@Description("If {@literal true}, save a heap dump before killing a thread or process "
+ "which is GC thrashing or out of memory.")
boolean getDumpHeapOnOOM();
void setDumpHeapOnOOM(boolean dumpHeapBeforeExit);

/**
* Creates a {@link PathValidator} object using the class specified in
* {@link #getPathValidatorClass()}.
Expand Down