<ruby id="bdb3f"></ruby>

    <p id="bdb3f"><cite id="bdb3f"></cite></p>

      <p id="bdb3f"><cite id="bdb3f"><th id="bdb3f"></th></cite></p><p id="bdb3f"></p>
        <p id="bdb3f"><cite id="bdb3f"></cite></p>

          <pre id="bdb3f"></pre>
          <pre id="bdb3f"><del id="bdb3f"><thead id="bdb3f"></thead></del></pre>

          <ruby id="bdb3f"><mark id="bdb3f"></mark></ruby><ruby id="bdb3f"></ruby>
          <pre id="bdb3f"><pre id="bdb3f"><mark id="bdb3f"></mark></pre></pre><output id="bdb3f"></output><p id="bdb3f"></p><p id="bdb3f"></p>

          <pre id="bdb3f"><del id="bdb3f"><progress id="bdb3f"></progress></del></pre>

                <ruby id="bdb3f"></ruby>

                企業??AI智能體構建引擎,智能編排和調試,一鍵部署,支持知識庫和私有化部署方案 廣告
                負載均衡維護一個活動 Sink列表的索引來實現負載的分配。支持了 **輪詢(round_robin)** 和 **隨機(random)** 兩種選擇機制分配負載,默認是輪詢,可以通過配置來更改。也可以從 AbstractSinkSelector 繼承寫一個自定義的選擇器。 :-: ![](https://img.kancloud.cn/55/e2/55e2159707eedb0bb0c99b5fb17792cc_1043x607.png) 負載均衡 Agent1會根據負載的機制來選擇上面三個Sink中的哪一個進行工作。 <br/> 工作時,此選擇器使用其配置的選擇機制選擇下一個 Sink 并調用它。如果所選Sink無法正常工作,則處理器通過其配置的選擇機制選擇下一個可用Sink。此實現不會將失敗的 Sink 列入黑名單,而是繼續樂觀地嘗試每個可用的 Sink。 <br/> 如果所有 Sink 調用都失敗了,選擇器會將故障拋給 Sink 的運行器。<br/> 如果backoff設置為true則啟用了退避機制,失敗的Sink會被放入黑名單,達到一定的超時時間后會自動從黑名單移除。如從黑名單出來后Sink仍然失敗,則再次進入黑名單而且超時時間會翻倍,以避免在無響應的 Sink 上浪費過長時間。 如果沒有啟用退避機制,在禁用此功能的情況下,發生 Sink 傳輸失敗后,會將本次負載傳給下一個 Sink 繼續嘗試,因此這種情況下是不均衡的。<br/> 示例: ```conf ######### Agent ############ a1.sources = r1 a1.channels = c1 a1.sinks = s1 s2 s3 # Sink 組邏輯器 a1.sinkgroups = g1 ######### Sources ########## a1.sources.r1.type = netcat a1.sources.r1.bind = hadoop101 a1.sources.r1.port = 6666 ########### SinkGroups ############# # 將上面定義的Sink加入到組中 a1.sinkgroups.g1.sinks = s1 s2 s3 # load_balance為負載均衡組件 a1.sinkgroups.g1.processor.type = load_balance # 失敗的 sink 是否成倍地增加退避它的時間。 a1.sinkgroups.g1.processor.backoff = true # 負載均衡機制,可選值:round_robin (輪詢)、 random (隨機選擇)、「自定義選擇器的全限定類名」 a1.sinkgroups.g1.processor.selector = random ############ Channel ########### a1.channels.c1.type = memory ########## Sinks ################ a1.sinks.s1.type = avro a1.sinks.s1.hostname = hadoop101 a1.sinks.s1.port = 7777 a1.sinks.s2.type = avro a1.sinks.s2.hostname = hadoop101 a1.sinks.s2.port = 8888 a1.sinks.s3.type = avro a1.sinks.s3.hostname = hadoop101 a1.sinks.s3.port = 9999 ########## 連接 ########### a1.sources.r1.channels = c1 a1.sinks.s1.channel = c1 a1.sinks.s2.channel = c1 a1.sinks.s3.channel = c1 ```
                  <ruby id="bdb3f"></ruby>

                  <p id="bdb3f"><cite id="bdb3f"></cite></p>

                    <p id="bdb3f"><cite id="bdb3f"><th id="bdb3f"></th></cite></p><p id="bdb3f"></p>
                      <p id="bdb3f"><cite id="bdb3f"></cite></p>

                        <pre id="bdb3f"></pre>
                        <pre id="bdb3f"><del id="bdb3f"><thead id="bdb3f"></thead></del></pre>

                        <ruby id="bdb3f"><mark id="bdb3f"></mark></ruby><ruby id="bdb3f"></ruby>
                        <pre id="bdb3f"><pre id="bdb3f"><mark id="bdb3f"></mark></pre></pre><output id="bdb3f"></output><p id="bdb3f"></p><p id="bdb3f"></p>

                        <pre id="bdb3f"><del id="bdb3f"><progress id="bdb3f"></progress></del></pre>

                              <ruby id="bdb3f"></ruby>

                              哎呀哎呀视频在线观看