OriginalCompleteBeforeOriginalCompleteAfterBeforeAfterProjectCommitCompilationUnitLineNosNamesTemplateVariableToCodeBeforeRelevantImportsTemplateVariableToCodeAfterisRelevantisSafe
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()))flink265140fdc84e765ecf48e9c34c47cda9fd143552org.apache.flink.runtime.operators.coordination.ComponentClosingUtils
_170
_271
_1closeTimeoutMs
_2closeTimeout
TCIVarcloseTimeoutMs
v1componentName
v3future
v4TimeUnit.MILLISECONDS
  • org.apache.flink.runtime.concurrent.FutureUtils
TCIVarcloseTimeoutMs
v1componentName
v3future
v4TimeUnit.MILLISECONDS
UsesFalse