Hi Kevin Kwon ~ Do you want to customize only the source operator name or all the operator name in order for the state compatibility ?
State compatibility is an orthogonal topic and keep the operator name is one way to solve it. Kevin Kwon <fsw0...@gmail.com> 于2020年11月25日周三 上午1:11写道: > For SQLs, I know that the operator ID assignment is not possible now since > the query optimizer may not be backward compatible in each release > > But are DDLs also affected by this? > > for example, > > CREATE TABLE mytable ( > id BIGINT, > data STRING > ) with ( > connector = 'kafka' > ... > id = 'mytable' > name = 'mytable' > ) > > and we can save all related checkpoint data >