flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-runtime/src/test/java/org/apache/flink/runtime/util/BlockerCheckpointStreamFactory.java
//We override this to ensure that writes go through the blocking #write(int) method!
We override this to ensure that writes go through the blocking #write(int) method!
We override this to ensure that writes go through the blocking #write ( int ) method!
@Override
			public void write(byte[] b, int off, int len) throws IOException {
				for (int i = 0; i < len; i++) {
					write(b[off + i]);
				}
			}
@ Override public void write ( byte [ ] b , int off , int len ) throws IOException { for ( int i = 0 ; i < len ; i ++ ) { write ( b [ off + i ] ) ; } }
We override this to ensure that writes go through the blocking #write(int) method!
We override this to ensure that writes go through the blocking #write ( int ) method!