測試為單Source以及非共享TaskSlot的單Map操作。Same Host表示兩個TaskManager是否在同一臺機器上運行。 | | | | | | ------------ | -------- | ---------- | --------- | | Message Size | Parallel | Throughput" />

国产xxxx99真实实拍_久久不雅视频_高清韩国a级特黄毛片_嗯老师别我我受不了了小说

資訊專欄INFORMATION COLUMN

【Flink實時計算 UFlink】性能數據

Tecode / 1937人閱讀

摘要:性能數據吞吐量測試為單以及非共享的單操作。表示兩個是否在同一臺機器上運行。吞吐量測試邏輯為單,后接共享的操作且該為有狀態操作,其狀態為給定大小的數組。

性能數據

吞吐量

測試為單Source以及非共享TaskSlot的單Map操作。Same Host表示兩個TaskManager是否在同一臺機器上運行。
Message SizeParallelThroughputSame Host
10241400 MB/sTrue
10241360 MB/sFalse
1024 * 10241345 MB/sFalse
1024 * 10241278 MB/sFalse

延遲

測試為單Source以及非共享TaskSlot的單Map操作。Same Host表示兩個TaskManager是否在同一臺機器上運行。
Message SizeParallel延遲中位數
4 byte129 ms

Kafka Consumer

測試邏輯為單Kafka Source,后接共享TaskSlot的Map操作。
Message SizeBroker SizePartition SizeReplica SizeConsumer ParallelCheckpoint EnabledThroughput
10243331False230 MB/s
10243333False370 MB/s
10243331True230 MB/s
10243333True370 MB/s

Kafka Consumer

測試邏輯為單字符串生成Source,后接共享TaskSlot的Kafka Sink。
Message SizeBroker SizePartition SizeReplica SizeAckParallelThroughput
1024333-1175 MB/s
10243331180 MB/s
100333-1155 MB/s
1003331157 MB/s

HDFS/Rocksdb checkpoint吞吐量

測試邏輯為單Source,后接共享TaskSlot的Map操作;且該Source為有狀態操作,其狀態為給定大小的byte數組。
Stated Source ParallelCheckpoint IntervalCheckpoint state Sizehdfsrocksdb
110000 ms200 MB133 MB/s100 MB/s
310000 ms200 MB (each)200 MB/s128 MB/s
110000 ms100 MB133 MB/s100 MB/s
310000 ms100 MB (each)150 MB/s150 MB/s

Flink hdfs checkpoint 延遲

測試邏輯為單Source,后接共享TaskSlot的Map操作;且該Source為有狀態操作,其狀態為給定大小的byte數組。
Stated Source ParallelCheckpoint IntervalCheckpoint state SizeAVG Checkpoint Time
15000 ms5kb48 ms
35000 ms5kb (each state)100 ms

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

文章版權歸作者所有,未經允許請勿轉載,若此文章存在違規行為,您可以聯系管理員刪除。

轉載請注明本文地址:http://specialneedsforspecialkids.com/yun/126206.html

相關文章

  • Flink實時計算 UFlink】什么是實時計算、產品優勢、版本支持

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

    Tecode 評論0 收藏0
  • Flink實時計算 UFlink】UFlink開發注意事項

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

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

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

    Tecode 評論0 收藏0
  • Flink實時計算 UFlink】基于Maven開發指南

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

    Tecode 評論0 收藏0
  • Flink實時計算 UFlink】集群管理

    摘要:集群管理進入集群管理頁面通過集群列表頁面進入集群管理頁面獲取集群詳情通過集群列表的詳情按鈕進入詳情頁面調整集群大小點擊調整容量調整集群大小查看點擊詳情頁的按鈕查看查看任務歷史點擊詳情頁的按鈕查看歷史任務節點密碼重置點擊集群列表頁的集群管理1. 進入集群管理頁面通過UFlink集群列表頁面進入集群管理頁面:2. 獲取集群詳情通過集群列表的詳情按鈕進入詳情頁面:3. 調整集群大小點擊調整容量調整...

    Tecode 評論0 收藏0

發表評論

0條評論

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