Hi， 我看了下Descriptor的代码，如果数据源是Kafka应该有地方绕，很绕, 你可以试下，建议使用DDL。
Best Leonard Xu [1] https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/table/descriptors/Kafka.java#L111 <https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/table/descriptors/Kafka.java#L111> [2] https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSourceSinkFactoryTestBase.java#L156 <https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSourceSinkFactoryTestBase.java#L156> > 在 2020年5月28日，00:45，macia kk <[email protected]> 写道： > > Hi 各位大佬 > > .field("event_time", TIMESTAMP()).rowtime( > new Rowtime() > .timestampsFromField("maxwell_ts") > .watermarksPeriodicBounded(60000) > ) > > > 我这个 maxwell_ts 是 milliseconds ，直接这么用会报错： > > Type TIMESTAMP(6) of table field ‘event_time’ does not match with the > physical type > > > 有类似 > > event_time as to_timestamp(maxwell_ts) > > > 这么的操作码？
