checkState(pendingReferences.get() > 0,STR0); | checkState(numUnconsumedSubpartitions > 0,STR0); | pendingReferences.get() | pendingReferences | flink | acd15d2527e7c8c137cb8719e15da3edc0a2c994 | org.apache.flink.runtime.io.network.partition.ReleaseOnConsumptionResultPartition | | _1 | pendingReferences |
---|
_2 | numUnconsumedSubpartitions |
---|
| | | | Uses | True |
System.out.printf(STR0,name,received.get()); | System.out.printf(STR0,name,received); | received.get() | received | JGroups | b070b9678f8198f51aac50e1ebe3235a11b33217 | org.jgroups.tests.OrderingTest.MyReceiver | | | | | | Uses | True |