“But I think the planner needs to know whether the input is insert-only or not.”
Does fromDataStream(dataStream, schema, changelogMode) solve your concerns ? People can pass around whatever ChangelogMode they like as an optional param. By default: fromDataStream(dataStream, schema), the ChangelogMode is INSERT. Best, Danny Chan 在 2020年9月9日 +0800 PM2:53，dev@flink.apache.org，写道： > > But I think the planner needs to > know whether the input is insert-only or not.
