[BEAM-3935] FileChannel instance should be closed in ArtifactServiceStager#StagingCallable#get

• Type: Bug
• Status: Open
• Priority: P3
• Resolution: Unresolved
• Component/s: runner-core
• Assignee: Unassigned
• Reporter: Ted Yu
• Created: 26/Mar/18 21:06
• Updated: 03/Jun/22 20:29

Description

      FileChannel channel = new FileInputStream(file).getChannel();
      ByteBuffer readBuffer = ByteBuffer.allocate(bufferSize);
      while (!responseObserver.isTerminal() && channel.position() < channel.size()) {
        readBuffer.clear();
        channel.read(readBuffer);

The channel should be closed before returning from get()