%flink.ssql(type=update)                                                          DROP VIEW IF EXISTS EVENTS_LEFT_JOIN_DELIVERED;
CREATE VIEW EVENTS_LEFT_JOIN_DELIVERED AS
SELECT
  C.*
FROM
    EVENTS C
LEFT OUTER JOIN
    DELIVERED_EVENTS D
ON
C.`Id1` = D.`Id1` 
AND C.`Time` BETWEEN D.`timestamp` AND  D.`timestamp` + INTERVAL '1' MINUTE;

TableException: StreamPhysicalOverAggregate doesn't support consuming update and delete changes which is produced by node Join(joinType=[LeftOuterJoin], where=[((Id1 = Id1) AND (Time >= timestamp) AND (Time <= (timestamp + 60000:INTERVAL MINUTE)))], select=[EventId,contentId, timestamp], leftInputSpec=[NoUniqueKey], rightInputSpec=[NoUniqueKey])