SET execution.checkpointing.interval = 3s; CREATE TABLE user_source( id INT, name STRING, address STRING, phone_number STRING, email STRING, PRIMARY KEY (`id`) NOT ...