help: resize method can not work in my project

[gy09535]

Base issue #1374 .I use the resize method to change my channel size ,but it dose not work.
As I check the kubenetes code on #1533 , I find the link of kubenetes code is missing(https://github.com/kubernetes/kubernetes/blob/master/pkg/kubelet/server/remotecommand/websocket.go).
I confused is the feature abandoned or my code problem. Flowing is my code:

    @Override
    public void afterConnectionEstablished(WebSocketSession session) throws Exception {
        WsQuery query = getWsQuery(session.getAttributes());
        KubeWsOutputStream outputStream = new KubeWsOutputStream(session);
        ExecWatch execWatch;
        KubeWsBashInputStream inputStream = new KubeWsBashInputStream(session);
        if (StringUtils.isNotEmpty(query.getContainer())) {
            execWatch = KubeProxyContainer.get(query.getEnv()).pods().inNamespace(query.getNamespace()).withName(query.getName())
                    .inContainer(query.getContainer())
                    .readingInput(inputStream)
                    .writingOutput(outputStream)
                    .writingError(outputStream).withTTY().exec("/bin/bash");
        } else {
            execWatch = KubeProxyContainer.get(query.getEnv()).pods().inNamespace(query.getNamespace()).withName(query.getName())
                    .readingInput(inputStream)
                    .writingOutput(outputStream)
                    .writingError(outputStream).withTTY().exec("/bin/bash");
        }

        inputStream.setExecWatch(execWatch);
        this.execWatch = execWatch;
        KubeInputStreamManager.addInputStream(session.getId(), inputStream);
    }

    @Override
    public void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
        if (message.getPayload().startsWith("{")) {
            log.info("[handleTextMessage] receive resize data:{}", message.getPayload());
            try {
                ResizeRequest resizeRequest = objectMapper.readValue(message.getPayload(), ResizeRequest.class);
                execWatch.resize(resizeRequest.cols, resizeRequest.rows);
            } catch (Exception e) {
                log.warn("[handleTextMessage] resize request fail, request: {}, error: {}", message.getPayload(), e.getMessage());
            } finally {
                return;
            }
        }

        KubeInputStreamManager.enQueueBytes(session.getId(), message.getPayload().getBytes(StandardCharsets.UTF_8));
    }

[stale]

This issue has been automatically marked as stale because it has not had any activity since 90 days. It will be closed if no further activity occurs within 7 days. Thank you for your contributions!