A method for processing data using a distributed data processing system including a plurality of processing nodes (140, 150a, 150b, 150c), the method including: receiving input data at a distributed data processing system interface component in communication with the distributed data processing system, wherein the input data includes a data processing task; providing the received input data to the distributed data processing system, wherein the distributed data processing system assigns an indicator associated with a first time interval of a plurality of time intervals to the input data, wherein the first time interval is a working time when the input data is received by the distributed data processing system; generating state information within the distributed data processing system in response to receiving the input data, wherein the state information includes the indicator associated with the first time interval; at the distributed data processing system interface component, receiving from the distributed data processing system and storing result data generated by processing the input data at a processing node of the plurality of processing nodes (140, 150a, 150b, 150c), wherein the result data includes a result of the data processing task and an indicator associated with a second time interval later than the first time interval, wherein the second time interval is a working time when the result data is generated or transmitted; determining, at a first processing node (140, 150a, 150b, 150c) of the plurality of processing nodes (140, 150a, 150b, 150c), an indicator of an earliest time interval (145, 146) of the plurality of time intervals for which all results of data processing tasks that have been generated by processing received data processing tasks at the plurality of processing nodes (140, 150a, 150b, 150c)have been stored at a first or second level of durability; providing the indicator of the earliest time interval (145, 146) to the distributed data processing system interface component; determining whether to release a result corresponding to the result data from the distributed data processing system interface component based on a comparison, at the distributed data processing system interface component, of the indicator of the earliest time interval (145, 146) to the indicator, associated with the second time interval, included in the result data; and releasing the result from the distributed data processing system interface component if the indicator of the earliest time interval (145, 146) corresponds to a time interval identical to or later than the second time interval. receiving input data at a distributed data processing system interface component in communication with the distributed data processing system, wherein the input data includes a data processing task; providing the received input data to the distributed data processing system, wherein the distributed data processing system assigns an indicator associated with a first time interval of a plurality of time intervals to the input data, wherein the first time interval is a working time when the input data is received by the distributed data processing system; generating state information within the distributed data processing system in response to receiving the input data, wherein the state information includes the indicator associated with the first time interval; at the distributed data processing system interface component, receiving from the distributed data processing system and storing result data generated by processing the input data at a processing node of the plurality of processing nodes (140, 150a, 150b, 150c), wherein the result data includes a result of the data processing task and an indicator associated with a second time interval later than the first time interval, wherein the second time interval is a working time when the result data is generated or transmitted; determining, at a first processing node (140, 150a, 150b, 150c) of the plurality of processing nodes (140, 150a, 150b, 150c), an indicator of an earliest time interval (145, 146) of the plurality of time intervals for which all results of data processing tasks that have been generated by processing received data processing tasks at the plurality of processing nodes (140, 150a, 150b, 150c)have been stored at a first or second level of durability; providing the indicator of the earliest time interval (145, 146) to the distributed data processing system interface component; determining whether to release a result corresponding to the result data from the distributed data processing system interface component based on a comparison, at the distributed data processing system interface component, of the indicator of the earliest time interval (145, 146) to the indicator, associated with the second time interval, included in the result data; and releasing the result from the distributed data processing system interface component if the indicator of the earliest time interval (145, 146) corresponds to a time interval identical to or later than the second time interval.