A data processing method, wherein the method is performed by a physical machine in a stream system, the physical machine comprises a first executor , and the method comprises: predicting traffic of a to-be-processed data stream of the first executor in a first time period according to historical information about processing data by the first executor, so as to obtain prediction information of the traffic of the data stream in the first time period, wherein the historical information comprises traffic information of data processed by the first executor in a historical time period, and the traffic prediction information comprises predictors of traffic at multiple moments in the first time period; if the traffic prediction information comprises a predictor that exceeds a threshold, reducing a data obtaining velocity of the first executor from a first velocity to a second velocity; and obtaining a first data set of the to-be-processed data stream at the second velocity; characterized in that the method further comprises: if the first data set is greater than a maximum data processing threshold of the first executor , stopping obtaining data in the to-be-processed data stream by enabling a backpressure control policy, wherein the maximum data processing threshold of the first executer is a value that is determined according to a hardware configuration or a software configuration of the first executer that indicates a maximum amount of data that can be processed in a unit time. predicting traffic of a to-be-processed data stream of the first executor in a first time period according to historical information about processing data by the first executor, so as to obtain prediction information of the traffic of the data stream in the first time period, wherein the historical information comprises traffic information of data processed by the first executor in a historical time period, and the traffic prediction information comprises predictors of traffic at multiple moments in the first time period; if the traffic prediction information comprises a predictor that exceeds a threshold, reducing a data obtaining velocity of the first executor from a first velocity to a second velocity; and obtaining a first data set of the to-be-processed data stream at the second velocity; characterized in that the method further comprises: if the first data set is greater than a maximum data processing threshold of the first executor , stopping obtaining data in the to-be-processed data stream by enabling a backpressure control policy, wherein the maximum data processing threshold of the first executer is a value that is determined according to a hardware configuration or a software configuration of the first executer that indicates a maximum amount of data that can be processed in a unit time. if the first data set is greater than a maximum data processing threshold of the first executor , stopping obtaining data in the to-be-processed data stream by enabling a backpressure control policy, wherein the maximum data processing threshold of the first executer is a value that is determined according to a hardware configuration or a software configuration of the first executer that indicates a maximum amount of data that can be processed in a unit time. <EOS>