public class PipelinedApproximateSubpartition extends PipelinedSubpartition
|Modifier and Type||Method and Description|
To simply the view releasing threading model,
abortCheckpoint, acknowledgeAllDataProcessed, add, addRecovered, alignedBarrierTimeout, bufferSize, finish, flush, getAvailabilityAndBacklog, getBuffersInBacklogUnsafe, getChannelStateCheckpointId, getNumberOfQueuedBuffers, getTotalNumberOfBuffersUnsafe, getTotalNumberOfBytesUnsafe, isReleased, release, requestBufferBuilderBlocking, setChannelStateWriter, toString, unsynchronizedGetNumberOfQueuedBuffers
add, getSubPartitionIndex, getSubpartitionInfo, onConsumedSubpartition
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
public PipelinedSubpartitionView createReadView(BufferAvailabilityListener availabilityListener)
releaseView()is called only before creating a new view.
There is still one corner case when a downstream task fails continuously in a short period of time then multiple netty worker threads can createReadView at the same time. TODO: This problem will be solved in FLINK-19774
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.