flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStore.java
/**
	 * Converts a path to the checkpoint id.
	 *
	 * @param path in ZooKeeper
	 * @return Checkpoint id parsed from the path
	 */
Converts a path to the checkpoint id.
@param path in ZooKeeper
@return Checkpoint id parsed from the path
Converts a path to the checkpoint id . @param path in ZooKeeper @return Checkpoint id parsed from the path
public static long pathToCheckpointId(String path) {
		try {
			String numberString;
			if ('/' == path.charAt(0) ) {
				numberString = path.substring(1);
			} else {
				numberString = path;
			}
			return Long.parseLong(numberString);
		} catch (NumberFormatException e) {
			LOG.warn("Could not parse checkpoint id from {}. This indicates that the " +
				"checkpoint id to path conversion has changed.", path);
			return -1L;
		}
	}
public static long pathToCheckpointId ( String path ) { try { String numberString ; if ( '/' == path . charAt ( 0 ) ) { numberString = path . substring ( 1 ) ; } else { numberString = path ; } return Long . parseLong ( numberString ) ; } catch ( NumberFormatException e ) { LOG . warn ( "Could not parse checkpoint id from {}. This indicates that the " + "checkpoint id to path conversion has changed." , path ) ; return - 1L ; } }
Converts a path to the checkpoint id.
Converts a path to the checkpoint id .
// check if we have a leading slash