Distributed multi-environment stream computing

A computer program product comprising one or more computer readable storage media and program instructions collectively stored on the one or more computer readable storage media, the stored program instructions executable by a stream processing management node, the stored program instructions comprising:

• program instructions to establish 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;
• program instructions to distribute 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;
• program instructions to receive, 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;
• and
• program instructions to perform a machine learning based stream management operation based, at least in part, on the received processing results.

A computer system comprising a stream processing management node having a processor set and a computer readable storage medium, wherein:

• the processor set is structured, located, connected and/or programmed to run program instructions stored on the computer readable storage medium;
• and
• the stored program instructions include:
• program instructions to establish 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;
• program instructions to distribute 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;
• program instructions to receive, 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;
• and
• program instructions to perform a machine learning based stream management operation based, at least in part, on the received processing results.