1.Doris官網(wǎng)

Doris官網(wǎng)https://doris.apache.org/

2.根本原因

本地idea訪問FE，F(xiàn)E會返回BE的地址，但是在服務器上通過ip addr查看，發(fā)現(xiàn)只有局域網(wǎng)IP，所以FE返回了局域網(wǎng)的IP，導致idea連接不上BE

3.解決辦法

重寫B(tài)ackendV2類，返回公網(wǎng)IP即可。

在項目下新建包名

org.apache.doris.flink.rest.models

然后放入?BackendV2類

package org.apache.doris.flink.rest.models;

import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
import com.fasterxml.jackson.annotation.JsonProperty;

import java.util.List;

/**
 * @Project_Name:Realtime
 * @Package_Name:org.apache.doris.flink.rest.models
 * @Class_Name:BackendV2
 * @Auther:zhang pengyun
 * @Date:2023-07-25 21:06
 * @Description:
 */
@JsonIgnoreProperties(ignoreUnknown = true)
public class BackendV2 {

    @JsonProperty(value = "backends")
    private List<BackendRowV2> backends;

    public List<BackendRowV2> getBackends() {
        return backends;
    }

    public void setBackends(List<BackendRowV2> backends) {
        this.backends = backends;
    }

    public static class BackendRowV2 {
        public String ip;
        public int http_port;
        public boolean is_alive;

        public String getIp() {
            return ip;
        }

        public void setIp(String ip) {
            this.ip = ip;
        }

        public int getHttpPort() {
            return http_port;
        }

        public void setHttpPort(int httpPort) {
            this.http_port = httpPort;
        }

        public boolean isAlive() {
            return is_alive;
        }

        public void setAlive(boolean alive) {
            is_alive = alive;
        }

        public String toBackendString(){
            return "47.92.168.70" + ":" + http_port;
        }

    }
}

然后重寫修改toBackendString()方法，將公網(wǎng)IP寫死返回，如果有多個BE，可以通過判斷ip屬性的值，動態(tài)返回。?文章來源地址http://www.zghlxwxcb.cn/news/detail-620903.html

4.?注意事項

1. 一定要打開檢查點?。?！
2. idea連接，要連接FE的leader
3. 把日志級別設置為warn
4. FlinkSql一定要把print()方法注釋，否則不往下游傳數(shù)據(jù)

5.?flink寫doris(使用sink)

5.1 API

5.2 SQL

5.?flink寫doris(使用jdbc)

到了這里，關于Doris注意事項，Doris部署在阿里云，寫不進去數(shù)據(jù)的文章就介紹完了。如果您還想了解更多內(nèi)容，請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關文章，希望大家以后多多支持TOY模板網(wǎng)！