本发明公开了一种基于Flink实时计算司机服务订单时长的方法及系统，具体涉及数据处理技术领域，使用Flink的窗口操作定义业务数据源中司机的出收车事件和订单事件，作为输入事件流，并定义事件类型字段，用于区分出收车和订单事件，并划分时间分片，在每个时间分片中，根据司机ID和订单ID进行分组，计算每个司机在每个时间分片内每笔订单的服务时长，并汇总每分片每订单的司机服务时长；将每个时间分片内的最大服务时长按照司机ID进行聚合，得到每个司机在任意时间段的服务订单时长，并设定司机疲劳驾驶时长的阈值，根据司机在任意时间段的服务订单时长数据，判断是否超过阈值，评估司机的疲劳驾驶情况。