亚洲中字慕日产2020,大陆极品少妇内射AAAAAA,无码av大香线蕉伊人久久,久久精品国产亚洲av麻豆网站

資訊專欄INFORMATION COLUMN

【Flink實時計算 UFlink】UFlink開發(fā)注意事項

Tecode / 2134人閱讀

摘要:開發(fā)注意事項基于托管集群的應(yīng)用開發(fā),和自建集群類似,但是仍然有幾個地方需要注意。和默認配置托管集群默認指定以及的堆大小為,目前不支持進行更改單個中的數(shù)量設(shè)置為高可用配置應(yīng)用的高可用由集群以及共同保證。配置集群的運行時狀態(tài)保存在的指定目錄中。

UFlink開發(fā)注意事項

基于UFlink托管集群的Flink應(yīng)用開發(fā),和自建集群類似,但是仍然有幾個地方需要注意。

JobManager和TaskManager默認配置

1. 托管集群默認指定JobManager以及TaskManager的堆大小為2GB,目前不支持進行更改;

2. 單個TaskManager中的TaskSlot數(shù)量設(shè)置為1;

高可用配置

Flink應(yīng)用的高可用由Yarn集群以及zookeeper共同保證。在Flink應(yīng)用因各種原因出現(xiàn)問題時,會觸發(fā)HA機制保證任務(wù)繼續(xù)運行:

1. 當TaskManager節(jié)點出問題之后,F(xiàn)link的JobManager會向Yarn申請新的TaskManager資源,保證任務(wù)的運行;

2.
當JobManager節(jié)點出現(xiàn)問題之后,Yarn會根據(jù)配置重啟JobManager,而后者會從zookeeper中獲取舊得運行數(shù)據(jù),并回恢復(fù)運行,從而恢復(fù)運行。

由于Yarn集群基于2.7.7版本,僅支持對重啟次數(shù)進行限定,目前設(shè)置的AM重啟次數(shù)最大為5次,即yarn.resourcemanager.am.max-attempts設(shè)置為5。

Checkpoint/Savepoint配置

Flink集群的運行時狀態(tài)保存在hdfs的指定目錄中。

1. Checkpoint的默認目錄為/flink-cluster/checkpoints;

2. Savepoint的默認目錄為/flink-cluster/savepoints;

3. Statebackend默認為filesystem,state.backend.incremental設(shè)置為true;

注意:在自定義checkpoint或者savepoint的目錄時,請盡量使用默認的值。其它目錄不保證用戶有權(quán)限寫入,而且不保證文件的持久性。

實時文檔歡迎https://docs.ucloud.cn/uflink/dev/note

文章版權(quán)歸作者所有,未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址:http://www.ezyhdfw.cn/yun/126204.html

相關(guān)文章

  • Flink實時計算 UFlink】基于Maven開發(fā)指南

    摘要:基于開發(fā)指南本節(jié)主要介紹如何創(chuàng)建項目,并開發(fā)簡單的應(yīng)用,從而使該應(yīng)用可以被提交到平臺運行。如果不設(shè)置為,可能會導(dǎo)致的類沖突,產(chǎn)生不可預(yù)見的問題。在自動生成的文件中,使用了來更方便的控制依賴的可見性。基于Maven開發(fā)指南本節(jié)主要介紹如何創(chuàng)建項目,并開發(fā)簡單的Flink應(yīng)用,從而使該Flink應(yīng)用可以被提交到UFlink平臺運行。==== 自動生成代碼框架 ==== 對于Java開發(fā)者,可以使...

    Tecode 評論0 收藏0
  • Flink實時計算 UFlink】UFlink SQL 開發(fā)指南

    摘要:開發(fā)指南是為簡化計算模型,降低用戶使用實時計算的門檻而設(shè)計的一套符合標準語義的開發(fā)套件。隨后,將為該表生成字段,用于記錄并表示事件時間。UFlink SQL 開發(fā)指南UFlink SQL 是 UCloud 為簡化計算模型,降低用戶使用實時計算的門檻而設(shè)計的一套符合標準 SQL 語義的開發(fā)套件。接下來,開發(fā)者可以根據(jù)如下內(nèi)容,逐漸熟悉并使用 UFlink SQL 組件所提供的便捷功能。1 ...

    Tecode 評論0 收藏0
  • Flink實時計算 UFlink】基于gradle開發(fā)指南

    摘要:基于開發(fā)指南如果基于進行應(yīng)用開發(fā),需要在文件中加入如下配置注解注意修改的值,確保其符合您的應(yīng)用。應(yīng)用開發(fā)完成后,可以直接直接運行方法,在本地進行基本的測試?;趃radle開發(fā)指南如果基于gradle進行應(yīng)用開發(fā),需要在build.gradle文件中加入如下配置:buildscript { repositories { jcenter() // this applie...

    Tecode 評論0 收藏0
  • Flink實時計算 UFlink】什么是實時計算、產(chǎn)品優(yōu)勢、版本支持

    摘要:什么是實時計算實時計算基于構(gòu)建,為分布式高性能隨時可用以及準確的流處理應(yīng)用程序提供流處理框架,可用于流式數(shù)據(jù)處理等應(yīng)用場景。版本支持當前支持的版本為,,,可以在提交任務(wù)時選擇所使用的版本。什么是實時計算實時計算(UFlink)基于ApacheFlink構(gòu)建,為分布式、高性能、隨時可用以及準確的流處理應(yīng)用程序提供流處理框架,可用于流式數(shù)據(jù)處理等應(yīng)用場景。產(chǎn)品優(yōu)勢100%開源兼容基于開源社區(qū)版本...

    Tecode 評論0 收藏0
  • Flink實時計算 UFlink】快速上手

    摘要:快速上手進行基本設(shè)置選擇地域和可用區(qū)。節(jié)點固定為臺,節(jié)點最少為臺。設(shè)置訪問的賬號和密碼選擇計費方式支持按小時按月按年三種計費模式,其中選擇月付購至月末時,即從當前時刻購買至本月月底,下個月的賬單從日開始正常計費結(jié)算。快速上手1. 進行基本設(shè)置(1)選擇地域和可用區(qū)。當前支持北京二可用區(qū)E。(2)選擇VPC和子網(wǎng)。請注意不同地域之間內(nèi)網(wǎng)不互通。(3)設(shè)置集群名稱和業(yè)務(wù)組。2. 選擇軟件版本當前...

    Tecode 評論0 收藏0

發(fā)表評論

0條評論

最新活動
閱讀需要支付1元查看
<