源码类别
热门源码
 当前位置：源码 > Java源码 >

Java源码示例：org.apache.flink.runtime.state.StateUtil

示例1
@Override
public void discardState() {
	try {
		List<StateObject> toDispose =
			new ArrayList<>(
					managedOperatorState.size() +
					rawOperatorState.size() +
					managedKeyedState.size() +
					rawKeyedState.size());
		toDispose.addAll(managedOperatorState);
		toDispose.addAll(rawOperatorState);
		toDispose.addAll(managedKeyedState);
		toDispose.addAll(rawKeyedState);
		StateUtil.bestEffortDiscardAllStateObjects(toDispose);
	} catch (Exception e) {
		LOG.warn("Error while discarding operator states.", e);
	}
}
示例2
@Override
public void discardState() {
	try {
		List<StateObject> toDispose =
			new ArrayList<>(
					managedOperatorState.size() +
					rawOperatorState.size() +
					managedKeyedState.size() +
					rawKeyedState.size());
		toDispose.addAll(managedOperatorState);
		toDispose.addAll(rawOperatorState);
		toDispose.addAll(managedKeyedState);
		toDispose.addAll(rawKeyedState);
		StateUtil.bestEffortDiscardAllStateObjects(toDispose);
	} catch (Exception e) {
		LOG.warn("Error while discarding operator states.", e);
	}
}
示例3
@Override
public void discardState() {
	try {
		List<StateObject> toDispose =
			new ArrayList<>(
					managedOperatorState.size() +
					rawOperatorState.size() +
					managedKeyedState.size() +
					rawKeyedState.size() +
					inputChannelState.size() +
					resultSubpartitionState.size());
		toDispose.addAll(managedOperatorState);
		toDispose.addAll(rawOperatorState);
		toDispose.addAll(managedKeyedState);
		toDispose.addAll(rawKeyedState);
		toDispose.addAll(collectUniqueDelegates(inputChannelState, resultSubpartitionState));
		StateUtil.bestEffortDiscardAllStateObjects(toDispose);
	} catch (Exception e) {
		LOG.warn("Error while discarding operator states.", e);
	}
}
示例4
@Override
public void discardState() {
	try {
		StateUtil.bestEffortDiscardAllStateObjects(
			Arrays.asList(
				managedOperatorState,
				rawOperatorState,
				managedKeyedState,
				rawKeyedState));
	} catch (Exception e) {
		LOG.warn("Error while discarding operator states.", e);
	}
}
示例5
private void dispose(boolean releaseState) {

		synchronized (lock) {
			try {
				numAcknowledgedTasks = -1;
				if (!discarded && releaseState) {
					executor.execute(new Runnable() {
						@Override
						public void run() {

							// discard the private states.
							// unregistered shared states are still considered private at this point.
							try {
								StateUtil.bestEffortDiscardAllStateObjects(operatorStates.values());
								targetLocation.disposeOnFailure();
							} catch (Throwable t) {
								LOG.warn("Could not properly dispose the private states in the pending checkpoint {} of job {}.",
									checkpointId, jobId, t);
							} finally {
								operatorStates.clear();
							}
						}
					});

				}
			} finally {
				discarded = true;
				notYetAcknowledgedTasks.clear();
				acknowledgedTasks.clear();
				cancelCanceller();
			}
		}
	}
示例6
@Override
public void discardState() {
	try {
		StateUtil.bestEffortDiscardAllStateObjects(
			Arrays.asList(
				managedOperatorState,
				rawOperatorState,
				managedKeyedState,
				rawKeyedState));
	} catch (Exception e) {
		LOG.warn("Error while discarding operator states.", e);
	}
}
示例7
private void dispose(boolean releaseState) {

		synchronized (lock) {
			try {
				numAcknowledgedTasks = -1;
				if (!discarded && releaseState) {
					executor.execute(new Runnable() {
						@Override
						public void run() {

							// discard the private states.
							// unregistered shared states are still considered private at this point.
							try {
								StateUtil.bestEffortDiscardAllStateObjects(operatorStates.values());
								targetLocation.disposeOnFailure();
							} catch (Throwable t) {
								LOG.warn("Could not properly dispose the private states in the pending checkpoint {} of job {}.",
									checkpointId, jobId, t);
							} finally {
								operatorStates.clear();
							}
						}
					});

				}
			} finally {
				discarded = true;
				notYetAcknowledgedTasks.clear();
				acknowledgedTasks.clear();
				cancelCanceller();
			}
		}
	}
示例8
@Override
public void discardState() {
	try {
		StateUtil.bestEffortDiscardAllStateObjects(
			Arrays.asList(
				managedOperatorState,
				rawOperatorState,
				managedKeyedState,
				rawKeyedState));
	} catch (Exception e) {
		LOG.warn("Error while discarding operator states.", e);
	}
}
示例9
private void dispose(boolean releaseState) {

		synchronized (lock) {
			try {
				numAcknowledgedTasks = -1;
				if (!discarded && releaseState) {
					executor.execute(new Runnable() {
						@Override
						public void run() {

							// discard the private states.
							// unregistered shared states are still considered private at this point.
							try {
								StateUtil.bestEffortDiscardAllStateObjects(operatorStates.values());
								targetLocation.disposeOnFailure();
							} catch (Throwable t) {
								LOG.warn("Could not properly dispose the private states in the pending checkpoint {} of job {}.",
									checkpointId, jobId, t);
							} finally {
								operatorStates.clear();
							}
						}
					});

				}
			} finally {
				discarded = true;
				notYetAcknowledgedTasks.clear();
				acknowledgedTasks.clear();
				cancelCanceller();
			}
		}
	}
示例10
@Override
public void discardState() throws Exception {
	StateUtil.bestEffortDiscardAllStateObjects(stateObjects);
}
示例11
@Override
public void discardState() throws Exception {
	StateUtil.bestEffortDiscardAllStateObjects(subtaskStatesByOperatorID.values());
}
示例12
@Override
public void discardState() throws Exception {
	StateUtil.bestEffortDiscardAllStateObjects(stateObjects);
}
示例13
@Override
public void discardState() throws Exception {
	StateUtil.bestEffortDiscardAllStateObjects(subtaskStatesByOperatorID.values());
}
示例14
@Override
public void discardState() throws Exception {
	StateUtil.bestEffortDiscardAllStateObjects(stateObjects);
}
示例15
@Override
public void discardState() throws Exception {
	StateUtil.bestEffortDiscardAllStateObjects(subtaskStatesByOperatorID.values());
}