International Business Machines Corporation

Other

Scott A Schneider

Kun-Lung Wu

Bugra Gedik

Martin J Hirzel

Xiang Ni

Henrique Andrade

Yuzhe Tang

Xavier Rene Guérin

Patrick Youssi

Embodiments for automating multidimensional elasticity for streaming applications in a computing environment. Each operator in a streaming application may be identified and assigned into one of a variety of groups according to similar performance metrics. One or more threading models may be adjusted for one or more of the groups to one or more different regions of the streaming application.

Automated multidimensional elasticity for streaming application runtimes

A multithreading system that performs elastic threading and dynamic patching is provided. The system receives a compiled object of a computing process, the compiled object comprising a set of locking instructions for ensuring exclusive access of a resource by the computing process. The system determines a thread count for the computing process. When the thread count indicates that a single thread is allocated to execute the computing process, the system patches the compiled object with a set of no-operation (NOP) instructions in place of the set of locking instructions. When the thread count indicates that two or more threads are allocated to execute the computing process, the system patches the compiled object with the set of locking instructions in place of the set of NOP instructions. The system executes the computing process according to the patched compiled object.

Adaptive locking in elastic threading systems

RPM sensor for an automated clutch system

A wood monitoring system and method is disclosed for monitoring lumber characteristics (e.g., lumber moisture) in environments of extremely high and prolonged temperature and moisture, e.g., a kiln. The monitoring system and method includes:

Wireless in-kiln moisture sensor and system for use thereof

An embodiment of the invention provides a method for exploiting stateless and stateful data parallelism in a streaming application, wherein a compiler determines whether an operator of the streaming application is safe to parallelize based on a definition of the operator and an instance of the definition. The operator is not safe to parallelize when the operator has selectivity greater than 1, wherein the selectivity is the number of output tuples generated for each input tuple. Parallel regions are formed within the streaming application with the compiler when the operator is safe to parallelize. Synchronization strategies for the parallel regions are determined with the compiler, wherein the synchronization strategies are determined based on the definition of the operator and the instance of the definition. The synchronization strategies of the parallel regions are enforced with a runtime system.

Automatic exploitation of data parallelism in streaming applications

A method for adjusting a data parallel region of a stream processing application includes measuring congestion of each parallel channel of the data parallel region, measuring a total throughput of all the parallel channels, and adjusting the number of parallel channels based on the current measured congestion and throughput.

Elastic auto-parallelization for stream processing applications based on measured throughput and congestion

Elastic auto-parallelization for stream processing applications based on a measured throughput and congestion

An embodiment of the invention provides a method for adaptive auto-pipelining of a stream processing application, wherein the stream processing application includes one or more threads. Runtime of the stream processing application is initiated with a stream processing application manager. The stream processing application is monitored with a monitoring module during the runtime, wherein the monitoring of the stream processing application includes identifying threads in the stream processing application that execute operators in a data flow graph, and determining an amount of work that each of the threads are performing on operators of the logical data flow graph. A processor identifies one or more operators in the data flow graph to add one or more additional threads based on the monitoring of the stream processing application during the runtime.

Adaptive auto-pipelining for stream processing applications

A method to optimize performance of an operator on a computer system includes determining whether the system is busy, decreasing a software thread level within the operator if the system is busy, and increasing the software thread level within the operator if the system is not busy and a performance measure of the system at a current software thread level of the operator is greater than a performance measure of the system when the operator has a lower software thread level.

Performance optimization based on threshold performance measure by resuming suspended threads if present or by creating threads within elastic and data parallel operators

A method to avoid discarding a worn non-adjusting clutch cover by converting the worn non-adjusting clutch cover to an adjusting clutch cover for re-use. First, the convex portion of the non-adjusting cover is adapted to receive an adjusting ring having the embodiments of the adjusting rings known in the art. The convex portion is cleaned by taking about 0.20-0.030 of one inch depth from an inner surface of the convex portion. A threaded wall is defined in the inner surface such that the adjusting ring having an externally threaded surface can be threadably coupled to the internally threaded surface of the inner surface of the convex portion. An adjuster aperture is drilled through the cover to receive a ring adjuster that engages the adjusting ring for positional adjustment.

Growing community of inventors

Hawthorne, NY, United States of America

Scott A Schneider