IP Library Granted Patent US 12,743,317
Granted Patent B2
US 12,743,317 · App. 18/474,658 · Granted Sep 22, 2026

Dynamic resource management for stream analytics

Inventors: Giuseppe Coviello (Robbinsville, NJ); Kunal Rao (Monroe, NJ); Srimat Chakradhar (Manalapan, NJ); Priscilla Benedetti (Perugia, IT)
Assignee: NEC Corporation
G06F9/5055
View Patent ↗
Loading inventors, assignments & file history…
Monitor This Case
Get email alerts when status or documents change.
Order Certified Copies
Most orders are placed with the USPTO same day — all within 24 business hours.
Order via The Patent Place →
Pre-filled with this patent's details
Quick Facts
Patent No.
US 12,743,317
App. No.
18/474,658
Granted
Sep 22, 2026
Kind
B2
Abstract

A computer implemented method is provided for resource management of stream analytics at each individual node that includes computing a mean of output processing rate of microservices in a pipeline; and evaluating a state of each microservice of the microservices in the pipeline. The computer implemented method also includes selecting a single microservice from the pipeline for updating resources for an action that changes the state in single the microservice that is selected; and performing resource allocation update for the selected microservice. The computer implemented method may also include updating the state of the selected microservice.

Claims (33)

1 . A computer implemented method for resource management of stream analytics at each individual node comprising:

computing a mean of output processing rate of microservices in a pipeline;

evaluating a state of each microservice of the microservices in the pipeline, wherein the evaluating of the state employs a Q-learning workflow of a reinforcement learning (RL) method;

selecting a single microservice from the pipeline for updating resources for an action that changes the state in the single microservice that is selected, wherein in exploitation mode the microservice with a maximum Q-value is selected from the Q-learning workflow, wherein a Q-value illustrates a positive change in state for an allocation change;

performing resource allocation updates for the selected microservice; and

updating the state of the selected microservice with a chosen resource allocation.

2 . The computer implemented method of claim 1 , wherein the evaluating of the state of each activation state comprising storing a best Q-value for the each microservice.

3 . The computer implemented method of claim 1 , wherein in exploration mode to select the microservice for updating resources, the microservice for updating the resources is selected randomly.

4 . The computer implemented method of claim 1 , wherein performing the resource allocation updates includes computing an expected output processing rate.

5 . The computer implemented method of claim 1 , wherein the updating the state of the selected microservice with the resource allocation includes a reward computation and updating of a Q-value for the selected microservice using a Bellman's equation.

6 . The computer implemented method of claim 1 , wherein the resources are selected from nodes by availability of CPU cores and random access memory (RAM) availability.

7 . The computer implemented method of claim 1 , wherein the microservices are directed towards object identification from a video stream.

8 . The computer implemented method of claim 7 , wherein the object identification is facial recognition.

9 . A system for resource management of stream analytics at each individual node comprising:

a hardware processor; and

a memory that stores a computer program product, the computer program product when executed by the hardware processor, causes the hardware processor to:

compute a mean of output processing rate of microservices in a pipeline;

evaluate a state of each microservice of the microservices in the pipeline, wherein the evaluate of the state employs a Q-learning workflow of a reinforcement learning (RL) method;

select a single microservice from the pipeline for updating resources for an action that changes the state in the single microservice that is selected, wherein in exploitation mode the microservice with a maximum Q-value is selected from the Q-learning workflow, where a Q-value illustrates a positive change in state for an allocation change;

perform resource allocation updates for the selected microservice; and

update the state of the selected microservice with a chosen resource allocation.

10 . The system of claim 9 , wherein the evaluate of the state of each activation state comprising storing a best Q-value for the each microservice.

11 . The system of claim 9 , wherein in exploration mode to select the microservice for updating resources, the microservice for updating the resources is selected randomly.

12 . The system of claim 9 , wherein the perform the resource allocation updates includes computing an expected output processing rate.

13 . The system of claim 9 , wherein the updating the state of the selected microservice with the resource allocation includes a reward computation and updating of a Q-value for the selected microservice using a Bellman's equation.

14 . The system of claim 9 , wherein the resources are selected from nodes by availability of CPU cores and random access memory (RAM) availability.

15 . The system of claim 9 , wherein the microservices are directed towards object identification from a video stream.

16 . A computer program product for resource management of stream analytics at each individual node comprising a computer readable storage medium having computer readable program code embodied therewith the computer readable program code executable by a hardware processor to cause the hardware processor to:

compute, using the hardware processor, a mean of output processing rate of microservices in pipeline of edge node;

evaluate, using the hardware processor, a state of each microservice of the microservices in the pipeline, wherein the evaluate of the state employs a Q-learning workflow of a reinforcement learning (RL) method;

select, using the hardware processor, a single microservice from the pipeline for updating resources for an action that changes the state in the single microservice that is selected, wherein in exploitation mode the microservice with a maximum Q-value is selected from the Q-learning workflow, wherein a Q-value illustrates a positive change in state for an allocation change;

perform, using the hardware processor, resource allocation update for the selected microservice; and

update, using the hardware processor, the state of the selected microservice with a chosen resource allocation.

Assignments (2)
ASSIGNMENT OF ASSIGNOR'S INTEREST Recorded Jul 14, 2026
From: NEC LABORATORIES AMERICA, INC.
To: NEC CORPORATION
Reel/Frame 075265/0791 →
ASSIGNMENT OF ASSIGNOR'S INTEREST Recorded Sep 26, 2023
From: COVIELLO, GIUSEPPE; RAO, KUNAL; CHAKRADHAR, SRIMAT; BENEDETTI, PRISCILLA
To: NEC LABORATORIES AMERICA, INC.
Reel/Frame 065031/0139 →
Continuity (2)
Provisional Application 63411233 · Sep 29, 2022
Related Publication 20240118938A1 · Apr 11, 2024
References Cited (22)
US 11720397B2 · Yamazaki · 2023 [cited by examiner]
US 20120317578A1 · Kansal · 2012 [cited by examiner]
US 20150363124A1 · Rath · 2015 [cited by examiner]
US 20190325304A1 · Gottin · 2019 [cited by examiner]
US 20230315518A1 · Jung · 2023 [cited by examiner]
US 20240185098A1 · Kou · 2024 [cited by examiner]
US 20240428085A1 · Chalapathy · 2024 [cited by examiner]
CN 112035949 · 2020 [cited by examiner]
WO WO2022177566A1 · 2022 [cited by examiner]
Aydin, M. E., & Öztemel, E. (Dec. 1, 1999). Dynamic job-shop scheduling using reinforcement learning agents. Robotics and Autonomous Systems, 33(2-3), 169-178. [cited by applicant]
Coviello, G., Rao, K., Sankaradas, M., & Chakradhar, S. (Nov. 9, 2021). DataX: A system for Data eXchange and transformation of streams. In International Symposium on Intelligent and Distributed Computing (pp. 319-329).… [cited by applicant]
Hong, C. H., & Varghese, B. (Sep. 30, 2018). Resource management in fog/edge computing: a survey on architectures, infrastructure, and algorithms. ACM Computing Surveys (CSUR), 52(5), 1-37. [cited by applicant]
Ma, C. Y., Kadav, A., Melvin, I., Kira, Z., AlRegib, G., & Graf, H. P. (Jun. 18, 2018). Attend and interact: Higher-order object interactions for video understanding. In Proceedings of the IEEE Conference on Computer Vi… [cited by applicant]
Watkins, C. J., & Dayan, P. (May 1, 1992). Q-learning. Machine learning, 8, 279-292. [cited by applicant]
Zhang, W., & Dietterich, T. G. (Aug. 20, 1995). A reinforcement learning approach to job-shop scheduling. In IJCAI (vol. 95, pp. 1114-1120). [cited by applicant]
Belgacem, A., Mahmoudi, S., & Kihl, M. (Apr. 2, 2022). Intelligent multi-agent reinforcement learning model for resources allocation in cloud computing. Journal of King Saud University—Computer and Information Sciences,… [cited by applicant]
Zhang, M., Zhu, Y., Liu, J., Wang, F., & Wang, F. (Dec. 21, 2022). Charmseeker: Automated pipeline configuration for serverless video processing. IEEE/ACM Transactions on Networking, 30(6), 2730-2743. [cited by applicant]
WG, C. S. (Mar. 1, 2018). Cncf wg-serverless whitepaper v1. 0. [cited by applicant]
Coviello, G., Yang, Y., Rao, K., & Chakradhar, S. (Dec. 6, 2021). Magic-pipe: Self-optimizing video analytics pipelines. In Proceedings of the 22nd International Middleware Conference (pp. 79-90). [cited by applicant]
Jiao, L., Zhang, R., Liu, F., Yang, S., Hou, B., Li, L., & Tang, X. (Aug. 1, 2022). New generation deep learning for video object detection: A survey. IEEE Transactions on Neural Networks and Learning Systems, 33(8), 31… [cited by applicant]
Liu, X., Yu, J., Wang, J., & Gao, Y. (Apr. 28, 2020). Resource allocation with edge computing in IoT networks via machine learning. IEEE Internet of Things Journal, 7(4), 3415-3426. [cited by applicant]
Xie, R., Tang, Q., Qiao, S., Zhu, H., Yu, F. R., & Huang, T. (Oct. 5, 2021). When serverless computing meets edge computing: Architecture, challenges, and open issues. IEEE Wireless Communications, 28(5), 126-133. [cited by applicant]