search

StarRocks / starrocks-connector-for-apache-flink

Apache License 2.0
192 stars 154 forks source link

StarRocksSinkManagerV2 unsupport redirect becuase StreamLoadEntity is not repeatable #302

Closed MyLanPangzi closed 10 months ago

MyLanPangzi commented 10 months ago

https://github.com/StarRocks/starrocks-connector-for-apache-flink/blob/f55a5b874520fab6e077b1636b17091077fe5a1c/starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/http/StreamLoadEntity.java#L65

MyLanPangzi commented 10 months ago

com.starrocks.streamload.shade.org.apache.http.impl.execchain.RedirectExec#execute check entity isRepeatable but StreamLoadEntity return false causing request cannot redirect.

                if (!RequestEntityProxy.isRepeatable(currentRequest)) {
                    if (this.log.isDebugEnabled()) {
                        this.log.debug("Cannot redirect non-repeatable request");
                    }

                    return response;
                }
MyLanPangzi commented 10 months ago

StarRock Version: 3.1.0-1778465 sr flink connector version: flink-connector-starrocks-1.2.7_flink-1.14_2.11.jar