FutureUtils.orTimeout(future,closeTimeoutMs,TimeUnit.MILLISECONDS,String.format(STR0,componentName,closeTimeoutMs)); | FutureUtils.orTimeout(future,closeTimeout.toMillis(),TimeUnit.MILLISECONDS,String.format(STR1,componentName,closeTimeout.toMillis())); | FutureUtils.orTimeout(future,closeTimeoutMs,TimeUnit.MILLISECONDS,String.format(STR0,componentName,closeTimeoutMs)) | FutureUtils.orTimeout(future,closeTimeoutMs.toMillis(),TimeUnit.MILLISECONDS,String.format(STR1,componentName,closeTimeoutMs.toMillis())) | flink | 265140fdc84e765ecf48e9c34c47cda9fd143552 | org.apache.flink.runtime.operators.coordination.ComponentClosingUtils | | _1 | closeTimeoutMs |
---|
_2 | closeTimeout |
---|
| TCIVar | closeTimeoutMs |
---|
v1 | componentName |
---|
v3 | future |
---|
v4 | TimeUnit.MILLISECONDS |
---|
| - org.apache.flink.runtime.concurrent.FutureUtils
| TCIVar | closeTimeoutMs |
---|
v1 | componentName |
---|
v3 | future |
---|
v4 | TimeUnit.MILLISECONDS |
---|
| Uses | False |