[jira] [Created] (FLINK-29339) JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager blocks main thread

["Chesnay Schepler (Jira)" <ji...@apache.org>]

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)