[FLINK-18596] Derive format schema from table schema may get error result

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Won't Fix
• Affects Version/s: 1.11.0
• Component/s: Table SQL / API
• Labels: pull-request-available stale-major
• Assignee: Unassigned
• Reporter: jrthe42
• Created: 14/Jul/20 12:16
• Updated: 19/Feb/24 09:23
• Resolved: 29/Apr/21 16:00

Description

If rowtime attribute references a regular field, derive format schema from table schema may get error result:

Schema schema = new Schema()
	.field("f1", DataTypes.STRING())
	.field("f2", DataTypes.BIGINT()).from("t")
	.field("r", DataTypes.TIMESTAMP(3))
	.rowtime(
		new Rowtime().timestampsFromField("t").watermarksPeriodicBounded(3));

final Map<String, String> properties = schema.toProperties();
final TableSchema actualSchema = TableFormatFactoryBase.deriveSchema(properties);

this code snippet will result in `ValidationException("Field names must be unique. Duplicate field: '" + fullFieldName + "'")`, but the excepted result should be:

final TableSchema expectedSchema = TableSchema.builder()
	.field("f1", Types.STRING)
	.field("t", Types.LONG)
	.build();

Issue Links

• links to: GitHub Pull Request #12938