Chesnay Schepler created FLINK-29339:
----------------------------------------
Summary:
JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager
blocks main thread
Key: FLINK-29339
URL: https://issues.apache.org/jira/browse/FLINK-29339
Project: Flink
Issue Type: Bug
Components: Runtime / Coordination
Affects Versions: 1.16.0
Reporter: Chesnay Schepler
{code:java}
private List<ShuffleDescriptor> requestShuffleDescriptorsFromResourceManager(
IntermediateDataSetID intermediateDataSetID) {
Preconditions.checkNotNull(
resourceManagerGateway, "JobMaster is not connected to
ResourceManager");
try {
return this.resourceManagerGateway
.getClusterPartitionsShuffleDescriptors(intermediateDataSetID)
.get(); // <-- there's your problem
} catch (Throwable e) {
throw new RuntimeException(
String.format(
"Failed to get shuffle descriptors of intermediate
dataset %s from ResourceManager",
intermediateDataSetID),
e);
}
}
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
