Whenever schema changes in the source we should propagate that to the sink.
Whenever schema changes in the source we should propagate that to the sink.