in long-ride-alerts/src/solution/java/org/apache/flink/training/solutions/longrides/LongRidesSolution.java [167:173]
private long getTimerTime(TaxiRide ride) throws RuntimeException {
if (ride.isStart) {
return ride.eventTime.plusSeconds(120 * 60).toEpochMilli();
} else {
throw new RuntimeException("Can not get start time from END event.");
}
}