| 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 |