bug in CarEventSort.java

[bigflood]

"queueState.update(queue)" is missing at the end of the "onTimer" function.

flink-training-exercises/src/main/java/com/ververica/flinktraining/examples/datastream_java/process/CarEventSort.java

Lines 94 to 103 in 932ec20

	public void onTimer(long timestamp, OnTimerContext context, Collector<ConnectedCarEvent> out) throws Exception {
	PriorityQueue<ConnectedCarEvent> queue = queueState.value();
	Long watermark = context.timerService().currentWatermark();
	ConnectedCarEvent head = queue.peek();
	while (head != null && head.timestamp <= watermark) {
	out.collect(head);
	queue.remove(head);
	head = queue.peek();
	}
	}