買專利賣專利找龍圖騰，真高效！ 查專利查商標用IPTOP,全免費！專利年費監控用IP管家,真方便！

龍圖騰網恭喜北京思特奇信息技術股份有限公司申請的專利一種基于flink自定義sink的數據處理及推送方法及系統獲國家發明授權專利權，本發明授權專利權由國家知識產權局授予，授權公告號為：CN114661491B 。

龍圖騰網通過國家知識產權局官網在2025-05-16發布的發明授權授權公告中獲悉：該發明授權的專利申請號/專利號為：202210173702.4，技術領域涉及：G06F9/54；該發明授權一種基于flink自定義sink的數據處理及推送方法及系統是由肖燕珍設計研發完成，并于2022-02-24向國家知識產權局提交的專利申請。

本一種基于flink自定義sink的數據處理及推送方法及系統在說明書摘要公布了：本發明公開了一種基于flink自定義sink的數據處理及推送方法及系統，屬于數據處理技術領域。本發明方法，包括：對flink啟動命令中指定基本信息；在作業列表頁面啟動時，根據redis的值，判斷當前作業對應的主題是否已經啟動了作業；若沒有啟動作業則發送flink啟動命令并啟動作業，新增接數主題和表的關系到redis中；若已經啟動作業，則只新增接數主題和表的關系到redis；當啟動作業過程中對應的消息經過flink啟動命令的計算邏輯時，會根據redis中作業對應的表的json內容，確定對應的消息存儲的位置；在作業列表頁面停用時，若redis中接數主題對應的表只剩下當前作業對應的表，則執行yarnapplication?kill命令并關閉相應的作業，刪除redis中接數主題和表的關系。本發明減少了資源的消耗，以及運維成本。

本發明授權一種基于flink自定義sink的數據處理及推送方法及系統在權利要求書中公布了：1.一種基于flink自定義sink的數據處理及推送方法，所述方法包括：對flink啟動命令中指定基本信息；在作業列表頁面啟動時，根據redis的值，判斷當前作業對應的主題是否已經啟動了作業；若沒有啟動作業則發送flink啟動命令并啟動作業，新增接數主題和表的關系到redis中；若已經啟動作業，則只新增接數主題和表的關系到redis；當啟動作業過程中對應的消息經過flink啟動命令的計算邏輯時，會根據redis中作業對應的表的json內容，確定對應的消息存儲的位置；在作業列表頁面停用時，若redis中接數主題對應的表只剩下當前作業對應的表，則執行yarnapplication-kill命令并關閉相應的作業，刪除redis中接數主題和表的關系。

如需購買、轉讓、實施、許可或投資類似專利技術，可聯系本專利的申請人或專利權人北京思特奇信息技術股份有限公司，其通訊地址為：100086 北京市海淀區中關村南大街6號14層；或者聯系龍圖騰網官方客服，聯系龍圖騰網可撥打電話0551-65771310或微信搜索“龍圖騰網”。