US 12,079,659 B2
Selection of stream management operations based on machine learning in a distributed computing environment
Henry Chiu, San Jose, CA (US); Bradley William Fawcett, Byron, MN (US); Jingdong Sun, Rochester, MN (US); Jason A. Nikolai, Rochester, MN (US); and Paul Gerver, Rochester, MN (US)
Assigned to International Business Machines Corporation, Armonk, NY (US)
Filed by International Business Machines Corporation, Armonk, NY (US)
Filed on Dec. 15, 2020, as Appl. No. 17/122,197.
Prior Publication US 2022/0188149 A1, Jun. 16, 2022
Int. Cl. G06F 9/48 (2006.01); G06F 16/2455 (2019.01); G06F 16/2458 (2019.01); G06N 20/00 (2019.01); G06F 16/2453 (2019.01); H04N 21/25 (2011.01)
CPC G06F 9/4881 (2013.01) [G06F 16/24568 (2019.01); G06F 16/2471 (2019.01); G06N 20/00 (2019.01); G06F 9/48 (2013.01); G06F 16/24532 (2019.01); H04N 21/25 (2013.01)] 18 Claims
OG exemplary drawing
 
1. A computer-implemented method comprising:
establishing, by a stream processing management node, data communication between the stream processing management node and a plurality of stream processing instances executing on respective computing environments in a multi-environment computing system;
distributing, by the stream processing management node, one or more processing units of a stream processing job to a first set of stream processing instances of the plurality of stream processing instances;
receiving, by the stream processing management node, from the one or more stream processing instances of the first set of stream processing instances, processing results associated with the one or more processing units of the stream processing job;
training, by the stream processing management node, a machine learning model to select a stream management operation utilizing the received processing results as training data;
selecting, by the machine learning model, a first stream management operation; and
performing, by the stream processing management node, the first stream management operation.