[jira] [Created] (FLINK-18596) Derive format schema from table schema may get error result

["wangsan (Jira)" <ji...@apache.org>]

wangsan created FLINK-18596:
-------------------------------

             Summary: Derive format schema from table schema may get error result
                 Key: FLINK-18596
                 URL: https://issues.apache.org/jira/browse/FLINK-18596
             Project: Flink
          Issue Type: Bug
          Components: Table SQL / API
    Affects Versions: 1.11.0
            Reporter: wangsan


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

```java
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:

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



--
This message was sent by Atlassian Jira
(v8.3.4#803005)