fix(stream): set the correct initial checkpoint version to restore the operators state and add check for the initial destination tables.