Equipment failure risk detection and prediction in industrial process

A computer program product comprising a computer readable storage medium having program instructions embodied therewith, the program instructions executable by a device to cause the device to:

• determine from a cluster of nodes, a plurality of nodes storing equipment operations data associated with an operation performed by an equipment during a time range between an installation time and a maintenance time of the equipment;
• constructing a target table based on aggregated operation features determined from the plurality of nodes configured to execute a distributed processing operation in parallel, the distributed processing operation computing operation features associated with the equipment;
• and
• performing a risk failure analysis of an instance of the equipment based on the aggregated operation features stored in the target table,
• wherein the device is caused to determine from the cluster of nodes, the plurality of nodes storing the equipment operations data associated with the operation performed by the equipment during the time range between the installation time and the maintenance time, for multiple entries in parallel as distributed parallel processing.

A system of detecting equipment failure risk in an industrial process, comprising:

• at least one hardware processor communicatively coupled to a cluster of nodes storing a distributed file system;
• the at least one hardware processor operable to determine from the cluster of nodes, a plurality of nodes storing equipment operations data associated with an operation performed by an equipment during a time range between the installation time and the maintenance time of the equipment;
• the at least one hardware processor further operable to construct a target table based on aggregated operation features determined from the plurality of nodes configured to execute a distributed processing operation in parallel, the distributed processing operation computing operation features associated with the equipment;
• the at least one hardware processor further operable to perform a risk failure analysis of an instance of the equipment based on the aggregated operation features stored in the target table,
• wherein the at least one hardware processor determines from the cluster of nodes, the plurality of nodes storing the equipment operations data associated with the operation performed by the equipment during the time range between the installation time and the maintenance time, for multiple entries in parallel as distributed parallel processing.