买专利卖专利找龙图腾，真高效！ 查专利查商标用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或微信搜索“龙图腾网”。