Package | Description |
---|---|
org.apache.flink.runtime.executiongraph |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionJobVertex.resetForNewExecution(long timestamp,
long expectedGlobalModVersion) |
Execution |
ExecutionVertex.resetForNewExecution(long timestamp,
long originatingGlobalModVersion)
Archives the current Execution and creates a new Execution for this vertex.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.